Как динамически генерировать список нижестоящих задач из задачи в потоке

#python #airflow Вопрос: У меня есть основная задача, содержащая логику в этой функции Я не совсем уверен, как это сделать. Может быть, мне нужно еще одно промежуточное задание? Любая помощь…