在使用cloud-composer执行以下python脚本时,我在Airflow代码中的gcs2bq任务日志下获得了*** Task instance did not exist in the DB:from airflow.contrib.operators import dataproc_operator # Setting start date as yesterday starts the DAG immedi
我想收到一个电子邮件通知的任务成功,失败和重试在GCP使用Sendgrid。另外,当某些任务失败或重新尝试时,我也希望得到这些通知。我执行了以下步骤,并且在强制任务失败时没有收到任何通知。
from datetime import timedelta, datetime
from airflow import D