我有一个 DAG,它获取 Google 云存储桶中脚本的结果,将其加载到 Google BigQuery 中的表中,然后删除存储桶中的文件。
我希望 DAG 在周末每小时检查一次。现在,我正在使用 GoogleCloudStoragetoBigQueryOperator。如果该文件不存在,则 DAG 失败。有没有办法将 DAG 设置为即使文件不存在也不会失败?也许尝试/捕获?
python airflow
airflow ×1
python ×1