Návratové hodnoty funkce v TaskFlow
Tvůj tým ukládá konfiguraci pipeline do samostatného tasku, aby ji bylo možné znovu využít v navazujících krocích. Centralizace konfigurace tímto způsobem je v produkčním prostředí běžná: jeden task definuje nastavení a všechny ostatní tasky čtou stejné hodnoty místo toho, aby je měly natvrdo zakódované. Task get_config už vrací konfigurační slovník a run_pipeline je připraven ho použít.
Toto cvičení je součástí kurzu
Tvorba datových pipeline s Airflow
Interaktivní praktické cvičení
Proměňte teorii v praxi s jedním z našich interaktivních cvičení
Začít cvičení