`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.

Module Contents¶

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.
`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.

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.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.

airflow.providers.openlineage.conf¶

Module Contents¶

Functions¶

`airflow.providers.openlineage.conf`¶