При документировании Airflow DAG с помощью оператора '>>' я получаю некоторые ошибки на зависимостях между задачами. Если я высмеиваю операторы воздушного потока, то получаю сообщение об ошибке, что оператор «>>» не существует между объектами в python.
Есть ли способ пропустить некоторые строки кода (те, которые я создалили исключение?
Я действительно хочу избегать использования set_downstream нотации ...
airflow.exceptions.AirflowException: пытался создать отношения между задачами, которые неу меня еще нет DAG. Задайте группу доступности базы данных хотя бы для одной задачи и повторите попытку: [<Task(PubSubSubscriptionCreateOperator): create-subscription>, <Task(CustomPubSubSensor: pull-messages>]
при издевательстве:
TypeError: неподдерживаемые типы операндов для >>: 'PubSubSubscriptionCreateOperator'и' CustomPubSubSensor '