airflow.providers.openlineage.conf¶

此模块提供了安全检索和处理 OpenLineage 配置的函数。

对于遗留的布尔环境变量 OPENLINEAGE_AIRFLOW_DISABLE_SOURCE_CODE 和 OPENLINEAGE_DISABLED，为保持向后兼容性，任何不等于“true”、“1”或“t”的字符串都应被视为 False。对遗留变量的支持将在 Airflow 3 中移除。

函数¶

`decorator`(func)
`config_path`([check_legacy_env_var])	[openlineage] config_path。
`is_source_enabled`()	[openlineage] disable_source_code。
`disabled_operators`()	[openlineage] disabled_for_operators。
`selective_enable`()	[openlineage] selective_enable。
`spark_inject_parent_job_info`()	[openlineage] spark_inject_parent_job_info。
`spark_inject_transport_info`()	[openlineage] spark_inject_transport_info。
`custom_extractors`()	[openlineage] extractors。
`custom_run_facets`()	[openlineage] custom_run_facets。
`namespace`()	[openlineage] namespace。
`transport`()	[openlineage] transport。
`is_disabled`()	[openlineage] disabled + 检查是否存在任何配置。
`dag_state_change_process_pool_size`()	[openlineage] dag_state_change_process_pool_size。
`execution_timeout`()	[openlineage] execution_timeout。
`include_full_task_info`()	[openlineage] include_full_task_info。
`debug_mode`()	[openlineage] debug_mode。

airflow.providers.openlineage.conf.config_path(check_legacy_env_var=True)[source]¶

[openlineage] config_path。

airflow.providers.openlineage.conf.is_source_enabled()[source]¶

[openlineage] disable_source_code。

airflow.providers.openlineage.conf.disabled_operators()[source]¶

[openlineage] disabled_for_operators。

airflow.providers.openlineage.conf.selective_enable()[source]¶

[openlineage] selective_enable。

airflow.providers.openlineage.conf.spark_inject_parent_job_info()[source]¶

[openlineage] spark_inject_parent_job_info。

airflow.providers.openlineage.conf.spark_inject_transport_info()[source]¶

[openlineage] spark_inject_transport_info。

airflow.providers.openlineage.conf.custom_extractors()[source]¶

[openlineage] extractors。

airflow.providers.openlineage.conf.custom_run_facets()[source]¶

[openlineage] custom_run_facets。

airflow.providers.openlineage.conf.namespace()[source]¶

[openlineage] namespace。

airflow.providers.openlineage.conf.transport()[source]¶

[openlineage] transport。

airflow.providers.openlineage.conf.is_disabled()[source]¶

[openlineage] disabled + 检查是否存在任何配置。

airflow.providers.openlineage.conf.dag_state_change_process_pool_size()[source]¶

[openlineage] dag_state_change_process_pool_size。

airflow.providers.openlineage.conf.execution_timeout()[source]¶

[openlineage] execution_timeout。

airflow.providers.openlineage.conf.include_full_task_info()[source]¶

[openlineage] include_full_task_info。

airflow.providers.openlineage.conf.debug_mode()[source]¶

[openlineage] debug_mode。