AP
Что подразумевается под генерировать? Он выбирает следующий существующий
Size: a a a
2017 December 22
П
Именно генерировать? А что за задача?
сейчас сформулирую
П
Что подразумевается под генерировать? Он выбирает следующий существующий
динамическая генерация тут описана https://habrahabr.ru/company/mailru/blog/339392/
П
Так и что мешает поставить имя таски как надо? Он смотрит на task_id, а не на то, как у вас переменная в файле описания дага названа
2 день уже мучаюсь, найти не могу причину, вроде все как надо, вот подумал, может динамическая генерация не совместима с BranchOperaorPython
П
Ну так проверьте что таски нужные так и называются. Поставьте python callable типа return 'task name' и запустите даг с dummyoperator вместо целевых тасок
ок, попробую
П
Ну или покажите кусок кода где вы пришиваете к ветвящемуся оператору результаты и то, как вы ставите ему условие перехода.
сейчас подготовлю
П
Ну или покажите кусок кода где вы пришиваете к ветвящемуся оператору результаты и то, как вы ставите ему условие перехода.
AP
динамическая генерация тут описана https://habrahabr.ru/company/mailru/blog/339392/
Генирируется они не BranchPythonOperator а в файле скрипта. BranchOperator возвращает название задачи, которое должно быть выполнено следующее.
П
Генирируется они не BranchPythonOperator а в файле скрипта. BranchOperator возвращает название задачи, которое должно быть выполнено следующее.
эт я в курсе, у меня Branch возвращает имя таска ветвления
ДС
Мне кажется, телеграм жмёт
ДС
А где у тебя аргументы заполняются?
П
А где у тебя аргументы заполняются?
да
ДС
А, вижу