Определение порядка выполнения задач
Как мы уже знаем, сенсоры, как и другие задачи, используют синтаксис битового сдвига для определения зависимостей. Изучая определение рабочего процесса коллеги, вы пытаетесь разобраться, в каком порядке выполняются заданные задачи. В коде указано следующее:
pull_data_sensor >> clean >> run_ml_pipeline
initialize_process >> pull_data_sensor
run_ml_pipeline >> generate_reports
Это упражнение является частью курса
Введение в Apache Airflow на Python
Практическое интерактивное упражнение
Превратите теорию в практику с помощью одного из наших интерактивных упражнений
Начать упражнение