Airflow on_failure_callback 收到上下文参数,但我在哪里可以找到上下文包含的内容?
Airflow on_failure_callback receive a context argument, but where can I find what the context contains?
在哪里可以找到上下文字典包含的内容?
在文档中或在 Google.
中进行一些搜索后,我找不到有关它包含的密钥的任何信息
上下文来自以下code line。
它将具有以下字典的模板值(参见 source code):
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
在哪里可以找到上下文字典包含的内容? 在文档中或在 Google.
中进行一些搜索后,我找不到有关它包含的密钥的任何信息上下文来自以下code line。 它将具有以下字典的模板值(参见 source code):
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