`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。
`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)[源代码]¶

[openlineage] config_path。

airflow.providers.openlineage.conf.is_source_enabled()[源代码]¶

[openlineage] disable_source_code。

airflow.providers.openlineage.conf.disabled_operators()[源代码]¶

[openlineage] disabled_for_operators。

airflow.providers.openlineage.conf.selective_enable()[源代码]¶

[openlineage] selective_enable。

airflow.providers.openlineage.conf.spark_inject_parent_job_info()[源代码]¶

[openlineage] spark_inject_parent_job_info。

airflow.providers.openlineage.conf.custom_extractors()[源代码]¶

[openlineage] extractors。

airflow.providers.openlineage.conf.custom_run_facets()[源代码]¶

[openlineage] custom_run_facets。

airflow.providers.openlineage.conf.namespace()[源代码]¶

[openlineage] namespace。

airflow.providers.openlineage.conf.transport()[源代码]¶

[openlineage] transport。

airflow.providers.openlineage.conf.is_disabled()[源代码]¶

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

airflow.providers.openlineage.conf.dag_state_change_process_pool_size()[源代码]¶

[openlineage] dag_state_change_process_pool_size。

airflow.providers.openlineage.conf.execution_timeout()[源代码]¶

[openlineage] execution_timeout。

airflow.providers.openlineage.conf.include_full_task_info()[源代码]¶

[openlineage] include_full_task_info。

airflow.providers.openlineage.conf.debug_mode()[源代码]¶

[openlineage] debug_mode。