Передавайте в словаре в параметре templates_dict:

    ...
    provide_context=True,
    templates_dict={'sql': some_sql},
    ...

Получать внутри PythonOperator'а как kwargs['templates_dict']['sql']

спасибо, попробую

    ...
    provide_context=True,
    templates_dict={'sql': some_sql},
    ...

Спасибо, так всё работает :)

👍

Ещё один вопрос. Я с помощью цикла for создаю много тасков (см. картинку) каждый таск должен отдать свой результат через xcom следующему за ним соостветствующему таску (второму в этой цепочке). В этом втором таске xcom реализован внутри метода execute в операторе. Видимо я неправильно задаю параметр task_ids, так как метод compare_query = context['task_instance'].xcom_pull(key='return_value', task_ids='prepare_compare_query')  возвращает NoneType. Подскажите, как правильно задавать task_ids в такой ситуации?

а что возвращает предыдущий таск? Ну т.е. там задается key='return_value'?

да, предыдущий такс точно возвращает значения

мб в названии тасков ошибка?

насколько я понимаю, в параметре task_ids нужно писать имя конкретного таска, а у меня их много и их имена создаются циклом.

да, именно так

тогда нужно в параметрах передавать название предыдущего, например, ну или кусок _for_1_billinkg_id

в kwargs

если там вообще только числа отличаются, то можно только их

ага, то есть прямо в метод execute оператора? так?

get_actual_table_name = PythonOperator(
    task_id='get_actual_{zone}_table_name'.format(zone=zone),
    python_callable=get_actual_table_version,
    op_kwargs={'conn_id': 'conn_sf_{zone}_pg_gmtool'.format(zone=zone),
        'table_name_pattern': schema_name_no_quotes,
        'zone': zone,
        'table_name_arr': ['Table1', 'Table2', 'Table3']},
    provide_context=True,
    adhoc=True,
    dag=dag
)

вот как тут в op_kwargs

ага, спасибо, попробую