Ну вы кстати так логи потеряете если будет все время меняться окличество тасок

По идеи то можно...

Если не хотите отстрелить себе то что ниже пояса и породить ещё тонну вопросов а почему не запускаются таски - то оставьте эту затею))

ну да вот верно пишут что strange кейс

депенд он паст главное не ставить)

В аирфлоу в момент старта дага уже не получится изменить состав дага без последствий

а нет количество тасков меняться не будет

А в целом можно в DAG скрипте использовать то что вернул XСOM?

да, конечно

в пайтн операторе через контекст

или темплейтами можно

Для последующего формирования дага, нет либо с кучей геммороя

у меня есть таблица в бд, где я зазделил один скрипт на части
и через xcom хотел бы вызвать их

Главное операторы не создавать постоянно, и типа если переписать так чтобы просто из базы цикл например через hook ходить то почему нет

s = [{'ID': 1, 'TARGET_TABLE': 'test1', 'SOURCE_SQL': <cx_Oracle.LOB object at 0x7f7d9fecadc8>}, {'ID': 2, 'TARGET_TABLE': 'test1', 'SOURCE_SQL': <cx_Oracle.LOB object at 0x7f7d9fecadc8>}
Вот что вернул мне XCOM
И так хотел реализовать. Это тип шаблон, но не знаю как дернуть
for i in range(len(s)):
load_from_db = MsSqlToOracleTransfer(
           task_id= i['ID'],
           mssql_conn_id = 'host',
           oracle_conn_id = 'orcl_conn_id',
           sql=  i['SOURCE_SQL'],',
           oracle_table = 'i['TARGET_TABLE']            
       )

У кого какой опыт обновления airflow до версии 2.2.0?

С какой?

С последней, 2.1.4 или с 2.1.*

-, не так прочитал вопрос

Что-то вроде такого поймал?)