1. Učit se
    2. /
  2. Kurzy
    3. /
  3. Úvod do Apache Airflow v Pythonu
Connected

Cvičení

Spuštění podřízeného dagu

Všimneš si, že některé tvoje workflows sdílejí podobné komponenty, a uvědomíš si, že společné úlohy by bylo lepší vyčlenit do samostatného dagu. To ti umožní spouštět tyto komponenty podle potřeby, aniž by ses musel/a starat o údržbu více kopií. Rozhodneš se proto spustit podřízený dag pomocí úlohy v rámci aktuálního workflow.

Komponenty dag, task a datetime jsou už naimportované.

Pokyny

100 XP
  • Naimportuj operátor potřebný ke spuštění dagu z tvého workflow.
  • Nastav operátor tak, aby spouštěl dag s názvem child_pipeline.
  • Zajisti, aby nadřazený dag čekal na dokončení spuštěného dagu, než bude pokračovat.
  • Nastav, jak často má operátor kontrolovat, zda podřízený dag skončil.