• Home
• Index

Index

_

__version__ (in module airflow.providers.openlineage)

A

adapter (airflow.providers.openlineage.plugins.listener.OpenLineageListener attribute) add_extractor() (airflow.providers.openlineage.extractors.manager.ExtractorManager method) add_one() (in module tests.system.openlineage.example_openlineage_mapped_simple_dag) airflow.providers.openlineage module airflow.providers.openlineage.api module airflow.providers.openlineage.api.core module airflow.providers.openlineage.api.datasets module airflow.providers.openlineage.api.sql module airflow.providers.openlineage.conf module airflow.providers.openlineage.extractors module airflow.providers.openlineage.extractors.base module airflow.providers.openlineage.extractors.bash module airflow.providers.openlineage.extractors.manager module airflow.providers.openlineage.extractors.python module airflow.providers.openlineage.facets module airflow.providers.openlineage.get_provider_info module airflow.providers.openlineage.operators module airflow.providers.openlineage.operators.empty module airflow.providers.openlineage.plugins module airflow.providers.openlineage.plugins.adapter module airflow.providers.openlineage.plugins.facets module airflow.providers.openlineage.plugins.listener module

airflow.providers.openlineage.plugins.macros module airflow.providers.openlineage.plugins.openlineage module airflow.providers.openlineage.sqlparser module airflow.providers.openlineage.token_provider module airflow.providers.openlineage.utils module airflow.providers.openlineage.utils.selective_enable module airflow.providers.openlineage.utils.spark module airflow.providers.openlineage.utils.sql module airflow.providers.openlineage.utils.sql_hook_lineage module airflow.providers.openlineage.utils.utils module airflow.providers.openlineage.version_compat module AIRFLOW_CONNECTION_API_KEY_AUTH_TYPE (in module airflow.providers.openlineage.token_provider) AIRFLOW_V_3_0_PLUS (in module airflow.providers.openlineage.version_compat) AIRFLOW_V_3_2_PLUS (in module airflow.providers.openlineage.version_compat) AIRFLOW_VERSION (in module tests.system.openlineage.expected_events) AirflowConnectionConfigProvider (class in airflow.providers.openlineage.token_provider) AirflowConnectionTokenProvider (class in airflow.providers.openlineage.token_provider) AirflowDagRunFacet (class in airflow.providers.openlineage.plugins.facets) AirflowDebugRunFacet (class in airflow.providers.openlineage.plugins.facets) AirflowJobFacet (class in airflow.providers.openlineage.plugins.facets) AirflowMappedTaskRunFacet (class in airflow.providers.openlineage.plugins.facets) AirflowRunFacet (class in airflow.providers.openlineage.plugins.facets) AirflowStateRunFacet (class in airflow.providers.openlineage.plugins.facets) any() (in module tests.system.openlineage.operator) AnyOperator (in module airflow.providers.openlineage.utils.utils) AssetInfo (class in airflow.providers.openlineage.utils.utils) attach_column_lineage() (airflow.providers.openlineage.sqlparser.SQLParser method) authority (airflow.providers.openlineage.sqlparser.DatabaseInfo attribute)

B

BaseExtractor (class in airflow.providers.openlineage.extractors.base) BaseFacetSubclass (in module airflow.providers.openlineage.extractors.base) BashExtractor (class in airflow.providers.openlineage.extractors.bash) before_stopping() (airflow.providers.openlineage.plugins.listener.OpenLineageListener method) build_dag_run_id() (airflow.providers.openlineage.plugins.adapter.OpenLineageAdapter static method)

build_dag_run_ol_run_id() (in module airflow.providers.openlineage.utils.utils) build_task_event_job_facets() (in module airflow.providers.openlineage.utils.utils) build_task_event_run_facets() (in module airflow.providers.openlineage.utils.utils) build_task_instance_ol_run_id() (in module airflow.providers.openlineage.utils.utils) build_task_instance_run_id() (airflow.providers.openlineage.plugins.adapter.OpenLineageAdapter static method)

C

casts (airflow.providers.openlineage.utils.utils.DagInfo attribute) (airflow.providers.openlineage.utils.utils.DagRunInfo attribute) (airflow.providers.openlineage.utils.utils.InfoJsonEncodable attribute) (airflow.providers.openlineage.utils.utils.TaskInfo attribute) (airflow.providers.openlineage.utils.utils.TaskInstanceInfo attribute) clear_variables (tests.system.openlineage.operator.OpenLineageTestOperator attribute) COLUMN_NAME (airflow.providers.openlineage.utils.sql.ColumnIndex attribute) ColumnIndex (class in airflow.providers.openlineage.utils.sql) complete_task() (airflow.providers.openlineage.plugins.adapter.OpenLineageAdapter method) config_conn_id() (in module airflow.providers.openlineage.conf) config_path() (in module airflow.providers.openlineage.conf) conn_id (airflow.providers.openlineage.token_provider.AirflowConnectionConfigProvider attribute) (airflow.providers.openlineage.token_provider.AirflowConnectionTokenProvider attribute)

convert_to_ol_dataset() (airflow.providers.openlineage.extractors.manager.ExtractorManager static method) convert_to_ol_dataset_from_object_storage_uri() (airflow.providers.openlineage.extractors.manager.ExtractorManager static method) convert_to_ol_dataset_from_table() (airflow.providers.openlineage.extractors.manager.ExtractorManager static method) create_cluster (in module tests.system.openlineage.example_openlineage_setup_teardown_dag) create_filter_clauses() (in module airflow.providers.openlineage.utils.sql) create_information_schema_query() (airflow.providers.openlineage.sqlparser.SQLParser method) (in module airflow.providers.openlineage.utils.sql) create_namespace() (airflow.providers.openlineage.sqlparser.SQLParser static method) custom_extractors() (in module airflow.providers.openlineage.conf) custom_run_facets() (in module airflow.providers.openlineage.conf) CustomMappedOperator (class in tests.system.openlineage.example_openlineage_base_complex_dag)

D

dag (airflow.providers.openlineage.plugins.facets.AirflowDagRunFacet attribute) (airflow.providers.openlineage.plugins.facets.AirflowRunFacet attribute) dag_failed() (airflow.providers.openlineage.plugins.adapter.OpenLineageAdapter method) DAG_ID (in module tests.system.openlineage.example_openlineage_base_complex_dag) (in module tests.system.openlineage.example_openlineage_base_simple_dag) (in module tests.system.openlineage.example_openlineage_defer_simple_dag) (in module tests.system.openlineage.example_openlineage_docs_file_dag) (in module tests.system.openlineage.example_openlineage_mapped_simple_dag) (in module tests.system.openlineage.example_openlineage_schedule_asset_or_time_dag) (in module tests.system.openlineage.example_openlineage_schedule_cron_dag) (in module tests.system.openlineage.example_openlineage_schedule_list_complex_assets_dag) (in module tests.system.openlineage.example_openlineage_schedule_list_multiple_assets_dag) (in module tests.system.openlineage.example_openlineage_schedule_list_single_asset_dag) (in module tests.system.openlineage.example_openlineage_schedule_multiple_assets_dag) (in module tests.system.openlineage.example_openlineage_schedule_single_asset_dag) (in module tests.system.openlineage.example_openlineage_schedule_timetable_dag) (in module tests.system.openlineage.example_openlineage_setup_teardown_dag) (in module tests.system.openlineage.example_openlineage_short_circuit_dag) (in module tests.system.openlineage.example_openlineage_task_groups_dag) (in module tests.system.openlineage.example_openlineage_taskflow_simple_dag) (in module tests.system.openlineage.example_openlineage_trigger_dag) (in module tests.system.openlineage.example_openlineage_trigger_dag_deferrable) (in module tests.system.openlineage.example_openlineage_versioned_dag) dag_started() (airflow.providers.openlineage.plugins.adapter.OpenLineageAdapter method) dag_state_change_process_pool_size() (in module airflow.providers.openlineage.conf) dag_success() (airflow.providers.openlineage.plugins.adapter.OpenLineageAdapter method) dag_version_info() (airflow.providers.openlineage.utils.utils.DagRunInfo class method) DagInfo (class in airflow.providers.openlineage.utils.utils) dagRun (airflow.providers.openlineage.plugins.facets.AirflowDagRunFacet attribute) (airflow.providers.openlineage.plugins.facets.AirflowRunFacet attribute) DagRunInfo (class in airflow.providers.openlineage.utils.utils) dagRunState (airflow.providers.openlineage.plugins.facets.AirflowStateRunFacet attribute) database (airflow.providers.openlineage.sqlparser.DatabaseInfo attribute) (airflow.providers.openlineage.sqlparser.GetTableSchemasParams attribute) DATABASE (airflow.providers.openlineage.utils.sql.ColumnIndex attribute) database (airflow.providers.openlineage.utils.sql.TableSchema attribute)

DatabaseInfo (class in airflow.providers.openlineage.sqlparser) DatasetSubclass (in module airflow.providers.openlineage.extractors.base) deadlines() (airflow.providers.openlineage.utils.utils.DagRunInfo class method) debug_mode() (in module airflow.providers.openlineage.conf) decorator() (in module airflow.providers.openlineage.conf) default_extractor (airflow.providers.openlineage.extractors.manager.ExtractorManager attribute) DEFAULT_INFORMATION_SCHEMA_COLUMNS (in module airflow.providers.openlineage.sqlparser) DEFAULT_INFORMATION_SCHEMA_TABLE_NAME (in module airflow.providers.openlineage.sqlparser) DEFAULT_NAMESPACE (in module airflow.providers.openlineage.sqlparser) default_normalize_name_method() (in module airflow.providers.openlineage.sqlparser) default_schema (airflow.providers.openlineage.sqlparser.SQLParser attribute) DefaultExtractor (class in airflow.providers.openlineage.extractors.base) deferrable (tests.system.openlineage.example_openlineage_base_complex_dag.SomeCustomOperator attribute) dialect (airflow.providers.openlineage.sqlparser.SQLParser attribute) disable_lineage() (in module airflow.providers.openlineage.utils.selective_enable) DISABLE_OL_PARAM (in module airflow.providers.openlineage.utils.selective_enable) disabled_operators() (in module airflow.providers.openlineage.conf) do_nothing() (in module tests.system.openlineage.example_openlineage_base_complex_dag) (in module tests.system.openlineage.example_openlineage_base_simple_dag) (in module tests.system.openlineage.example_openlineage_setup_teardown_dag) (in module tests.system.openlineage.example_openlineage_short_circuit_dag) (in module tests.system.openlineage.example_openlineage_versioned_dag) do_nothing_task (in module tests.system.openlineage.example_openlineage_base_simple_dag) (in module tests.system.openlineage.example_openlineage_docs_file_dag) (in module tests.system.openlineage.example_openlineage_schedule_asset_or_time_dag) (in module tests.system.openlineage.example_openlineage_schedule_cron_dag) (in module tests.system.openlineage.example_openlineage_schedule_list_complex_assets_dag) (in module tests.system.openlineage.example_openlineage_schedule_list_multiple_assets_dag) (in module tests.system.openlineage.example_openlineage_schedule_list_single_asset_dag) (in module tests.system.openlineage.example_openlineage_schedule_multiple_assets_dag) (in module tests.system.openlineage.example_openlineage_schedule_single_asset_dag) (in module tests.system.openlineage.example_openlineage_schedule_timetable_dag) (in module tests.system.openlineage.example_openlineage_short_circuit_dag) (in module tests.system.openlineage.example_openlineage_trigger_dag) (in module tests.system.openlineage.example_openlineage_trigger_dag_deferrable) (in module tests.system.openlineage.example_openlineage_versioned_dag) duration() (airflow.providers.openlineage.utils.utils.DagRunInfo class method)

E

emit() (airflow.providers.openlineage.plugins.adapter.OpenLineageAdapter method) (in module airflow.providers.openlineage.api.core) (tests.system.openlineage.transport.variable.VariableTransport method) emit_dataset_lineage() (in module airflow.providers.openlineage.api.datasets) emit_lineage_from_sql_extras() (in module airflow.providers.openlineage.utils.sql_hook_lineage) emit_query_lineage() (in module airflow.providers.openlineage.api.sql) EmptyOperator (class in airflow.providers.openlineage.operators.empty) enable_lineage() (in module airflow.providers.openlineage.utils.selective_enable) ENABLE_OL_PARAM (in module airflow.providers.openlineage.utils.selective_enable) ENABLE_OL_PARAM_NAME (in module airflow.providers.openlineage.utils.selective_enable) env (tests.system.openlineage.operator.OpenLineageTestOperator attribute) env_var() (in module tests.system.openlineage.operator) event_count_assertions (tests.system.openlineage.operator.OpenLineageTestOperator attribute) event_sort_fn (tests.system.openlineage.operator.OpenLineageTestOperator attribute) event_templates (tests.system.openlineage.operator.OpenLineageTestOperator attribute) excludes (airflow.providers.openlineage.utils.utils.InfoJsonEncodable attribute) (airflow.providers.openlineage.utils.utils.TaskInfoComplete attribute) execute() (airflow.providers.openlineage.operators.empty.EmptyOperator method) (tests.system.openlineage.example_openlineage_base_complex_dag.CustomMappedOperator method) (tests.system.openlineage.operator.OpenLineageTestOperator method)

execution_timeout() (in module airflow.providers.openlineage.conf) executor (airflow.providers.openlineage.plugins.listener.OpenLineageListener property) external_dag_id (tests.system.openlineage.example_openlineage_base_complex_dag.SomeCustomOperator attribute) external_task_id (tests.system.openlineage.example_openlineage_base_complex_dag.SomeCustomOperator attribute) extra_key (airflow.providers.openlineage.token_provider.AirflowConnectionTokenProvider attribute) extract() (airflow.providers.openlineage.extractors.base.BaseExtractor method) (airflow.providers.openlineage.extractors.bash.BashExtractor method) (airflow.providers.openlineage.extractors.python.PythonExtractor method) extract_inlets_and_outlets() (airflow.providers.openlineage.extractors.manager.ExtractorManager method) extract_metadata() (airflow.providers.openlineage.extractors.manager.ExtractorManager method) extract_on_complete() (airflow.providers.openlineage.extractors.base.BaseExtractor method) (airflow.providers.openlineage.extractors.base.DefaultExtractor method) extract_on_failure() (airflow.providers.openlineage.extractors.base.BaseExtractor method) (airflow.providers.openlineage.extractors.base.DefaultExtractor method) extractor_manager (airflow.providers.openlineage.plugins.listener.OpenLineageListener attribute) ExtractorManager (class in airflow.providers.openlineage.extractors.manager) extractors (airflow.providers.openlineage.extractors.manager.ExtractorManager attribute)

F

fail_fast (tests.system.openlineage.operator.OpenLineageTestOperator attribute) fail_task() (airflow.providers.openlineage.plugins.adapter.OpenLineageAdapter method) fields (airflow.providers.openlineage.utils.sql.TableSchema attribute)

file_path (tests.system.openlineage.operator.OpenLineageTestOperator attribute) from_masker() (airflow.providers.openlineage.utils.utils.OpenLineageRedactor class method) from_table_meta() (in module airflow.providers.openlineage.sqlparser) from_task_instance() (airflow.providers.openlineage.plugins.facets.AirflowMappedTaskRunFacet class method)

G

generate_openlineage_metadata_from_sql() (airflow.providers.openlineage.sqlparser.SQLParser method) get_airflow_dag_run_facet() (in module airflow.providers.openlineage.utils.utils) get_airflow_debug_facet() (in module airflow.providers.openlineage.utils.utils) get_airflow_job_facet() (in module airflow.providers.openlineage.utils.utils) get_airflow_mapped_task_facet() (in module airflow.providers.openlineage.utils.utils) get_airflow_run_facet() (in module airflow.providers.openlineage.utils.utils) get_airflow_state_run_facet() (in module airflow.providers.openlineage.utils.utils) get_api_key() (airflow.providers.openlineage.token_provider.AirflowConnectionTokenProvider method) get_config() (airflow.providers.openlineage.token_provider.AirflowConnectionConfigProvider method) get_dag_documentation() (in module airflow.providers.openlineage.utils.utils) get_dag_job_dependency_facet() (in module airflow.providers.openlineage.utils.utils) get_dag_parent_run_facet() (in module airflow.providers.openlineage.utils.utils) get_dag_run_dag_and_task_from_ti() (in module airflow.providers.openlineage.utils.utils) get_expected_event_file_path() (in module tests.system.openlineage.expected_events) get_extractor_class() (airflow.providers.openlineage.extractors.manager.ExtractorManager method) get_filtered_unknown_operator_keys() (in module airflow.providers.openlineage.utils.utils) get_fully_qualified_class_name() (in module airflow.providers.openlineage.utils.utils) get_hook_lineage() (airflow.providers.openlineage.extractors.manager.ExtractorManager method) get_job_name() (in module airflow.providers.openlineage.utils.utils) get_metadata_from_parser() (airflow.providers.openlineage.sqlparser.SQLParser static method) get_openlineage_config() (airflow.providers.openlineage.plugins.adapter.OpenLineageAdapter method) get_openlineage_facets_on_complete() (airflow.providers.openlineage.operators.empty.EmptyOperator method) get_openlineage_facets_on_failure() (airflow.providers.openlineage.operators.empty.EmptyOperator method)

get_openlineage_facets_on_start() (airflow.providers.openlineage.operators.empty.EmptyOperator method) get_openlineage_facets_with_sql() (in module airflow.providers.openlineage.sqlparser) get_openlineage_listener() (in module airflow.providers.openlineage.plugins.listener) get_operator_class() (in module airflow.providers.openlineage.utils.utils) get_operator_classnames() (airflow.providers.openlineage.extractors.base.BaseExtractor class method) (airflow.providers.openlineage.extractors.base.DefaultExtractor class method) (airflow.providers.openlineage.extractors.bash.BashExtractor class method) (airflow.providers.openlineage.extractors.python.PythonExtractor class method) get_operator_provider_version() (in module airflow.providers.openlineage.utils.utils) get_or_create_openlineage_client() (airflow.providers.openlineage.plugins.adapter.OpenLineageAdapter method) get_parent_information_from_dagrun_conf() (in module airflow.providers.openlineage.utils.utils) get_processing_engine_facet() (in module airflow.providers.openlineage.utils.utils) get_provider_info() (in module airflow.providers.openlineage.get_provider_info) get_root_information_from_dagrun_conf() (in module airflow.providers.openlineage.utils.utils) get_runtime_outlet_assets() (in module airflow.providers.openlineage.utils.utils) get_source_code() (airflow.providers.openlineage.extractors.python.PythonExtractor method) get_table_schemas() (in module airflow.providers.openlineage.utils.sql) get_task_documentation() (in module airflow.providers.openlineage.utils.utils) get_task_instance_from_context() (in module airflow.providers.openlineage.utils.utils) get_task_parent_run_facet() (in module airflow.providers.openlineage.utils.utils) get_unknown_source_attribute_run_facet() (in module airflow.providers.openlineage.utils.utils) get_user_provided_run_facets() (in module airflow.providers.openlineage.utils.utils) GetTableSchemasParams (class in airflow.providers.openlineage.sqlparser)

I

include_full_task_info() (in module airflow.providers.openlineage.conf) includes (airflow.providers.openlineage.utils.utils.AssetInfo attribute) (airflow.providers.openlineage.utils.utils.DagInfo attribute) (airflow.providers.openlineage.utils.utils.DagRunInfo attribute) (airflow.providers.openlineage.utils.utils.InfoJsonEncodable attribute) (airflow.providers.openlineage.utils.utils.TaskGroupInfo attribute) (airflow.providers.openlineage.utils.utils.TaskInfo attribute) (airflow.providers.openlineage.utils.utils.TaskInfoComplete attribute) (airflow.providers.openlineage.utils.utils.TaskInstanceInfo attribute) InfoJsonEncodable (class in airflow.providers.openlineage.utils.utils) information_schema_columns (airflow.providers.openlineage.sqlparser.DatabaseInfo attribute) (airflow.providers.openlineage.sqlparser.GetTableSchemasParams attribute) information_schema_table (airflow.providers.openlineage.sqlparser.GetTableSchemasParams attribute) information_schema_table_name (airflow.providers.openlineage.sqlparser.DatabaseInfo attribute) inject_parent_job_information_into_emr_serverless_properties() (in module airflow.providers.openlineage.utils.spark) inject_parent_job_information_into_glue_arguments() (in module airflow.providers.openlineage.utils.spark) inject_parent_job_information_into_spark_properties() (in module airflow.providers.openlineage.utils.spark) inject_transport_information_into_emr_serverless_properties() (in module airflow.providers.openlineage.utils.spark) inject_transport_information_into_glue_arguments() (in module airflow.providers.openlineage.utils.spark)

inject_transport_information_into_spark_properties() (in module airflow.providers.openlineage.utils.spark) inputs (airflow.providers.openlineage.extractors.base.OperatorLineage attribute) is_cross_db (airflow.providers.openlineage.sqlparser.GetTableSchemasParams attribute) is_dag_lineage_enabled() (in module airflow.providers.openlineage.utils.selective_enable) is_dag_run_asset_triggered() (in module airflow.providers.openlineage.utils.utils) is_datetime() (in module tests.system.openlineage.operator) is_disabled() (in module airflow.providers.openlineage.conf) is_information_schema_cross_db (airflow.providers.openlineage.sqlparser.DatabaseInfo attribute) is_json_serializable() (in module airflow.providers.openlineage.utils.utils) is_openlineage_active() (in module airflow.providers.openlineage.api.core) is_operator_disabled() (in module airflow.providers.openlineage.utils.utils) is_selective_lineage_enabled() (in module airflow.providers.openlineage.utils.utils) is_source_enabled() (in module airflow.providers.openlineage.conf) is_task_lineage_enabled() (in module airflow.providers.openlineage.utils.selective_enable) is_ti_rescheduled_already() (in module airflow.providers.openlineage.utils.utils) is_uppercase_names (airflow.providers.openlineage.sqlparser.DatabaseInfo attribute) (airflow.providers.openlineage.sqlparser.GetTableSchemasParams attribute) is_uuid() (in module tests.system.openlineage.operator) is_valid_uuid() (in module airflow.providers.openlineage.utils.utils)

J

job_facets (airflow.providers.openlineage.extractors.base.OperatorLineage attribute)

K

kind (tests.system.openlineage.transport.variable.VariableTransport attribute)

L

lineage_job_name() (in module airflow.providers.openlineage.plugins.macros) lineage_job_namespace() (in module airflow.providers.openlineage.plugins.macros) lineage_parent_id() (in module airflow.providers.openlineage.plugins.macros) lineage_root_job_name() (in module airflow.providers.openlineage.plugins.macros) lineage_root_job_namespace() (in module airflow.providers.openlineage.plugins.macros) lineage_root_parent_id() (in module airflow.providers.openlineage.plugins.macros) lineage_root_run_id() (in module airflow.providers.openlineage.plugins.macros) lineage_run_id() (in module airflow.providers.openlineage.plugins.macros) log (airflow.providers.openlineage.plugins.listener.OpenLineageListener attribute) (in module airflow.providers.openlineage.sqlparser) (in module airflow.providers.openlineage.utils.selective_enable) (in module airflow.providers.openlineage.utils.spark) (in module airflow.providers.openlineage.utils.sql) (in module airflow.providers.openlineage.utils.sql_hook_lineage) (in module airflow.providers.openlineage.utils.utils) (in module tests.system.openlineage.operator) (in module tests.system.openlineage.transport.variable)

log_submit_error() (airflow.providers.openlineage.plugins.listener.OpenLineageListener method)

M

macros (airflow.providers.openlineage.plugins.openlineage.OpenLineageProviderPlugin attribute) mapIndex (airflow.providers.openlineage.plugins.facets.AirflowMappedTaskRunFacet attribute) match() (in module tests.system.openlineage.operator) merge() (airflow.providers.openlineage.extractors.base.OperatorLineage method) module airflow.providers.openlineage airflow.providers.openlineage.api airflow.providers.openlineage.api.core airflow.providers.openlineage.api.datasets airflow.providers.openlineage.api.sql airflow.providers.openlineage.conf airflow.providers.openlineage.extractors airflow.providers.openlineage.extractors.base airflow.providers.openlineage.extractors.bash airflow.providers.openlineage.extractors.manager airflow.providers.openlineage.extractors.python airflow.providers.openlineage.facets airflow.providers.openlineage.get_provider_info airflow.providers.openlineage.operators airflow.providers.openlineage.operators.empty airflow.providers.openlineage.plugins airflow.providers.openlineage.plugins.adapter airflow.providers.openlineage.plugins.facets airflow.providers.openlineage.plugins.listener airflow.providers.openlineage.plugins.macros airflow.providers.openlineage.plugins.openlineage airflow.providers.openlineage.sqlparser airflow.providers.openlineage.token_provider airflow.providers.openlineage.utils airflow.providers.openlineage.utils.selective_enable airflow.providers.openlineage.utils.spark airflow.providers.openlineage.utils.sql airflow.providers.openlineage.utils.sql_hook_lineage airflow.providers.openlineage.utils.utils airflow.providers.openlineage.version_compat tests.system.openlineage tests.system.openlineage.example_openlineage_base_complex_dag tests.system.openlineage.example_openlineage_base_simple_dag tests.system.openlineage.example_openlineage_defer_simple_dag tests.system.openlineage.example_openlineage_docs_file_dag tests.system.openlineage.example_openlineage_mapped_simple_dag tests.system.openlineage.example_openlineage_schedule_asset_or_time_dag tests.system.openlineage.example_openlineage_schedule_cron_dag tests.system.openlineage.example_openlineage_schedule_list_complex_assets_dag tests.system.openlineage.example_openlineage_schedule_list_multiple_assets_dag tests.system.openlineage.example_openlineage_schedule_list_single_asset_dag tests.system.openlineage.example_openlineage_schedule_multiple_assets_dag tests.system.openlineage.example_openlineage_schedule_single_asset_dag tests.system.openlineage.example_openlineage_schedule_timetable_dag tests.system.openlineage.example_openlineage_setup_teardown_dag tests.system.openlineage.example_openlineage_short_circuit_dag tests.system.openlineage.example_openlineage_task_groups_dag tests.system.openlineage.example_openlineage_taskflow_simple_dag tests.system.openlineage.example_openlineage_trigger_dag tests.system.openlineage.example_openlineage_trigger_dag_deferrable tests.system.openlineage.example_openlineage_versioned_dag tests.system.openlineage.expected_events tests.system.openlineage.operator tests.system.openlineage.transport tests.system.openlineage.transport.variable

N

name (airflow.providers.openlineage.plugins.facets.UnknownOperatorInstance attribute) (airflow.providers.openlineage.plugins.openlineage.OpenLineageProviderPlugin attribute) namespace() (in module airflow.providers.openlineage.conf) next_query_counter_from_context() (in module airflow.providers.openlineage.utils.utils)

normalize_name (airflow.providers.openlineage.sqlparser.GetTableSchemasParams attribute) normalize_name_method (airflow.providers.openlineage.sqlparser.DatabaseInfo attribute) normalize_sql() (airflow.providers.openlineage.sqlparser.SQLParser class method) not_match() (in module tests.system.openlineage.operator) NoVariableError (in module tests.system.openlineage.operator)

O

obj (airflow.providers.openlineage.utils.utils.InfoJsonEncodable attribute) OL_METHOD_NAME_COMPLETE (in module airflow.providers.openlineage.extractors.base) OL_METHOD_NAME_FAIL (in module airflow.providers.openlineage.extractors.base) OL_METHOD_NAME_START (in module airflow.providers.openlineage.extractors.base) on_dag_run_failed() (airflow.providers.openlineage.plugins.listener.OpenLineageListener method) on_dag_run_running() (airflow.providers.openlineage.plugins.listener.OpenLineageListener method) on_dag_run_success() (airflow.providers.openlineage.plugins.listener.OpenLineageListener method) on_starting() (airflow.providers.openlineage.plugins.listener.OpenLineageListener method) on_task_instance_failed() (airflow.providers.openlineage.plugins.listener.OpenLineageListener method) on_task_instance_running() (airflow.providers.openlineage.plugins.listener.OpenLineageListener method) on_task_instance_skipped() (airflow.providers.openlineage.plugins.listener.OpenLineageListener method) on_task_instance_success() (airflow.providers.openlineage.plugins.listener.OpenLineageListener method)

openlineage_taskflow_simple_dag() (in module tests.system.openlineage.example_openlineage_taskflow_simple_dag) OpenLineageAdapter (class in airflow.providers.openlineage.plugins.adapter) OpenLineageAirflowConnectionAuthError OpenLineageAirflowConnectionConfigError OpenLineageListener (class in airflow.providers.openlineage.plugins.listener) OpenLineageProviderPlugin (class in airflow.providers.openlineage.plugins.openlineage) OpenLineageRedactor (class in airflow.providers.openlineage.utils.utils) OpenLineageTestOperator (class in tests.system.openlineage.operator) operator (airflow.providers.openlineage.extractors.base.BaseExtractor attribute) operatorClass (airflow.providers.openlineage.plugins.facets.AirflowMappedTaskRunFacet attribute) OperatorLineage (class in airflow.providers.openlineage.extractors.base) ORDINAL_POSITION (airflow.providers.openlineage.utils.sql.ColumnIndex attribute) outputs (airflow.providers.openlineage.extractors.base.OperatorLineage attribute)

P

packages (airflow.providers.openlineage.plugins.facets.AirflowDebugRunFacet attribute) parse() (airflow.providers.openlineage.sqlparser.SQLParser method) parse_query_result() (in module airflow.providers.openlineage.utils.sql)

parse_table_schemas() (airflow.providers.openlineage.sqlparser.SQLParser method) print_warning() (in module airflow.providers.openlineage.utils.utils) properties (airflow.providers.openlineage.plugins.facets.UnknownOperatorInstance attribute) PythonExtractor (class in airflow.providers.openlineage.extractors.python)

R

regex_match() (in module tests.system.openlineage.operator) renames (airflow.providers.openlineage.utils.utils.DagInfo attribute) (airflow.providers.openlineage.utils.utils.InfoJsonEncodable attribute) (airflow.providers.openlineage.utils.utils.TaskGroupInfo attribute) (airflow.providers.openlineage.utils.utils.TaskInfo attribute)

resolve_airflow_connection_auth() (in module airflow.providers.openlineage.token_provider) run_facets (airflow.providers.openlineage.extractors.base.OperatorLineage attribute)

S

safe_getattr() (in module airflow.providers.openlineage.utils.utils) schedule (in module tests.system.openlineage.example_openlineage_schedule_asset_or_time_dag) (in module tests.system.openlineage.example_openlineage_schedule_list_complex_assets_dag) SCHEMA (airflow.providers.openlineage.utils.sql.ColumnIndex attribute) schema (airflow.providers.openlineage.utils.sql.TableSchema attribute) scheme (airflow.providers.openlineage.sqlparser.DatabaseInfo attribute) selective_enable() (in module airflow.providers.openlineage.conf) serialize_timetable() (airflow.providers.openlineage.utils.utils.DagInfo class method) setproctitle (in module airflow.providers.openlineage.plugins.listener)

setup_jinja() (in module tests.system.openlineage.operator) should_use_external_connection() (in module airflow.providers.openlineage.utils.utils) SomeCustomOperator (class in tests.system.openlineage.example_openlineage_base_complex_dag) source_alias (airflow.providers.openlineage.utils.utils.AssetInfo attribute) spark_inject_parent_job_info() (in module airflow.providers.openlineage.conf) spark_inject_transport_info() (in module airflow.providers.openlineage.conf) split_sql_string() (airflow.providers.openlineage.sqlparser.SQLParser class method) SQLParser (class in airflow.providers.openlineage.sqlparser) start_task() (airflow.providers.openlineage.plugins.adapter.OpenLineageAdapter method) submit_callable() (airflow.providers.openlineage.plugins.listener.OpenLineageListener method)

T

T (in module airflow.providers.openlineage.utils.selective_enable) table (airflow.providers.openlineage.utils.sql.TableSchema attribute) TABLE_NAME (airflow.providers.openlineage.utils.sql.ColumnIndex attribute) TableSchema (class in airflow.providers.openlineage.utils.sql) TablesHierarchy (in module airflow.providers.openlineage.utils.sql) task (airflow.providers.openlineage.plugins.facets.AirflowRunFacet attribute) task_0 (in module tests.system.openlineage.example_openlineage_base_complex_dag) (in module tests.system.openlineage.example_openlineage_task_groups_dag) TaskGroupInfo (class in airflow.providers.openlineage.utils.utils) taskGroups (airflow.providers.openlineage.plugins.facets.AirflowJobFacet attribute) TaskInfo (class in airflow.providers.openlineage.utils.utils) TaskInfoComplete (class in airflow.providers.openlineage.utils.utils) taskInstance (airflow.providers.openlineage.plugins.facets.AirflowRunFacet attribute) TaskInstanceInfo (class in airflow.providers.openlineage.utils.utils) tasks (airflow.providers.openlineage.plugins.facets.AirflowJobFacet attribute) tasksDuration (airflow.providers.openlineage.plugins.facets.AirflowStateRunFacet attribute) tasksState (airflow.providers.openlineage.plugins.facets.AirflowStateRunFacet attribute) taskTree (airflow.providers.openlineage.plugins.facets.AirflowJobFacet attribute) taskUuid (airflow.providers.openlineage.plugins.facets.AirflowRunFacet attribute) test_run (in module tests.system.openlineage.example_openlineage_base_complex_dag) (in module tests.system.openlineage.example_openlineage_base_simple_dag) (in module tests.system.openlineage.example_openlineage_defer_simple_dag) (in module tests.system.openlineage.example_openlineage_docs_file_dag) (in module tests.system.openlineage.example_openlineage_mapped_simple_dag) (in module tests.system.openlineage.example_openlineage_schedule_asset_or_time_dag) (in module tests.system.openlineage.example_openlineage_schedule_cron_dag) (in module tests.system.openlineage.example_openlineage_schedule_list_complex_assets_dag) (in module tests.system.openlineage.example_openlineage_schedule_list_multiple_assets_dag) (in module tests.system.openlineage.example_openlineage_schedule_list_single_asset_dag) (in module tests.system.openlineage.example_openlineage_schedule_multiple_assets_dag) (in module tests.system.openlineage.example_openlineage_schedule_single_asset_dag) (in module tests.system.openlineage.example_openlineage_schedule_timetable_dag) (in module tests.system.openlineage.example_openlineage_setup_teardown_dag) (in module tests.system.openlineage.example_openlineage_short_circuit_dag) (in module tests.system.openlineage.example_openlineage_task_groups_dag) (in module tests.system.openlineage.example_openlineage_taskflow_simple_dag) (in module tests.system.openlineage.example_openlineage_trigger_dag) (in module tests.system.openlineage.example_openlineage_trigger_dag_deferrable) (in module tests.system.openlineage.example_openlineage_versioned_dag) tests.system.openlineage module tests.system.openlineage.example_openlineage_base_complex_dag module tests.system.openlineage.example_openlineage_base_simple_dag module tests.system.openlineage.example_openlineage_defer_simple_dag module tests.system.openlineage.example_openlineage_docs_file_dag module

tests.system.openlineage.example_openlineage_mapped_simple_dag module tests.system.openlineage.example_openlineage_schedule_asset_or_time_dag module tests.system.openlineage.example_openlineage_schedule_cron_dag module tests.system.openlineage.example_openlineage_schedule_list_complex_assets_dag module tests.system.openlineage.example_openlineage_schedule_list_multiple_assets_dag module tests.system.openlineage.example_openlineage_schedule_list_single_asset_dag module tests.system.openlineage.example_openlineage_schedule_multiple_assets_dag module tests.system.openlineage.example_openlineage_schedule_single_asset_dag module tests.system.openlineage.example_openlineage_schedule_timetable_dag module tests.system.openlineage.example_openlineage_setup_teardown_dag module tests.system.openlineage.example_openlineage_short_circuit_dag module tests.system.openlineage.example_openlineage_task_groups_dag module tests.system.openlineage.example_openlineage_taskflow_simple_dag module tests.system.openlineage.example_openlineage_trigger_dag module tests.system.openlineage.example_openlineage_trigger_dag_deferrable module tests.system.openlineage.example_openlineage_versioned_dag module tests.system.openlineage.expected_events module tests.system.openlineage.operator module tests.system.openlineage.transport module tests.system.openlineage.transport.variable module timetable_summary() (airflow.providers.openlineage.utils.utils.DagInfo class method) to_dataset() (airflow.providers.openlineage.utils.sql.TableSchema method) translate_airflow_asset() (in module airflow.providers.openlineage.utils.utils) transport() (in module airflow.providers.openlineage.conf) trigger_dagrun (in module tests.system.openlineage.example_openlineage_trigger_dag) (in module tests.system.openlineage.example_openlineage_trigger_dag_deferrable) trigger_dagrun2 (in module tests.system.openlineage.example_openlineage_trigger_dag_deferrable) try_import_from_string() (in module airflow.providers.openlineage.utils.utils) type (airflow.providers.openlineage.plugins.facets.UnknownOperatorInstance attribute) (airflow.providers.openlineage.utils.utils.AssetInfo attribute)

U

UDT_NAME (airflow.providers.openlineage.utils.sql.ColumnIndex attribute) ui_color (airflow.providers.openlineage.operators.empty.EmptyOperator attribute) unknownItems (airflow.providers.openlineage.plugins.facets.UnknownOperatorAttributeRunFacet attribute) UnknownOperatorAttributeRunFacet (class in airflow.providers.openlineage.plugins.facets)

UnknownOperatorInstance (class in airflow.providers.openlineage.plugins.facets) url_path() (in module tests.system.openlineage.operator) url_scheme_authority() (in module tests.system.openlineage.operator) use_flat_cross_db_query (airflow.providers.openlineage.sqlparser.DatabaseInfo attribute) (airflow.providers.openlineage.sqlparser.GetTableSchemasParams attribute)

V

validate_task_metadata() (airflow.providers.openlineage.extractors.manager.ExtractorManager method)

value (tests.system.openlineage.example_openlineage_base_complex_dag.CustomMappedOperator attribute) VariableTransport (class in tests.system.openlineage.transport.variable)

W

wait (in module tests.system.openlineage.example_openlineage_defer_simple_dag)

PreviousNext

Was this entry helpful?