Airflow on_failure_callback 接收上下文参数，但我在哪里可以找到上下文包含的内容？

Question

我在哪里可以找到上下文字典包含的内容？我在文档中或在 Google 中进行一些搜索后找不到有关它包含的密钥的任何信息。

Answer 1

上下文来自以下代码行。它将具有以下字典的模板化值（请参阅源代码）：

class Context(TypedDict, total=False):
    conf: AirflowConfigParser
    conn: Any
    dag: DAG
    dag_run: DagRun
    data_interval_end: DateTime
    data_interval_start: DateTime
    ds: str
    ds_nodash: str
    execution_date: DateTime
    exception: Union[Exception, str, None]
    inlets: list
    logical_date: DateTime
    macros: Any
    next_ds: Optional[str]
    next_ds_nodash: Optional[str]
    next_execution_date: Optional[DateTime]
    outlets: list
    params: ParamsDict
    prev_data_interval_start_success: Optional[DateTime]
    prev_data_interval_end_success: Optional[DateTime]
    prev_ds: Optional[str]
    prev_ds_nodash: Optional[str]
    prev_execution_date: Optional[DateTime]
    prev_execution_date_success: Optional[DateTime]
    prev_start_date_success: Optional[DateTime]
    run_id: str
    task: BaseOperator
    task_instance: TaskInstance
    task_instance_key_str: str
    test_mode: bool
    templates_dict: Optional[Mapping[str, Any]]
    ti: TaskInstance
    tomorrow_ds: str
    tomorrow_ds_nodash: str
    ts: str
    ts_nodash: str
    ts_nodash_with_tz: str
    var: _VariableAccessors
    yesterday_ds: str
    yesterday_ds_nodash: str