我正在为我的 ETL 使用 Airflow V2。我在这个 ETL 中使用 SnowflakeSqlSensor。在 Airflow V1 中,我使用的"fail_on_empty=True"
是 SnowflakeSqlSensor 中的参数。当我在 Airflow V2 中使用相同的参数时,我收到一条错误消息"Invalid argument"
。在 Airflow V2 文档中,我们看到这是一个有效的论点。fail_on_empty
在 Airflow V2中是否需要使用任何其他参数?此外,Airflow V2 中此参数的默认值是多少?
问问题
7 次