airflow.providers.openlineage.conf¶

This module provides functions for safely retrieving and handling OpenLineage configurations.

For the legacy boolean env variables OPENLINEAGE_AIRFLOW_DISABLE_SOURCE_CODE and OPENLINEAGE_DISABLED, any string not equal to “true”, “1”, or “t” should be treated as False, to maintain backward compatibility. Support for legacy variables will be removed in Airflow 3.

Functions¶

`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 + check if any configuration is present.
`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.

Module Contents¶

airflow.providers.openlineage.conf.decorator(func)[source]¶

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 + check if any configuration is present.

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.