airflow.providers.openlineage.conf

此模組提供安全地擷取和處理 OpenLineage 組態設定的功能。

對於舊版的布林環境變數 OPENLINEAGE_AIRFLOW_DISABLE_SOURCE_CODEOPENLINEAGE_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.decorator(func)[原始碼]
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。

這個條目是否有幫助?