В воздушном потоке мы можем установить строки jinja2 в `task_id`? - PullRequest
0 голосов
/ 11 марта 2019

Вопрос:

Могу ли я использовать строковый синтаксис jinja2 в task_id строке или мы ограничены f-string?

Пример:

Допустим, я использую BashOperator, а внутри я назначил params.Я могу успешно использовать эти params в своем bash_command, однако, как только я использую их в строку task_id, я получаю следующую ошибку:

airflow.exceptions.AirflowException: The key (my_task_id_string{{ params.paramname1}}{{ params.paramname2}}) has to be made of alphanumeric characters, dashes, dots and underscores

Вместо этого вЧтобы смягчить это, я вместо этого использую f-строку так: f"my_task_id_string{paramname1}{paramname2}"

...