• 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.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.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.utils module airflow.providers.openlineage.version_compat module AIRFLOW_V_3_0_PLUS (in module airflow.providers.openlineage.version_compat) AIRFLOW_VERSION (in module tests.system.openlineage.expected_events) 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) allow_duplicate_events_regex (tests.system.openlineage.operator.OpenLineageTestOperator attribute) 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_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) check_events_number_func() (in module tests.system.openlineage.example_openlineage_base_complex_dag) (in module tests.system.openlineage.example_openlineage_defer_simple_dag) (in module tests.system.openlineage.example_openlineage_mapped_simple_dag) (in module tests.system.openlineage.example_openlineage_short_circuit_dag) 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_path() (in module airflow.providers.openlineage.conf) 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) 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) (tests.system.openlineage.transport.variable.VariableTransport method) 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_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) 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_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_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_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_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_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_spark_properties() (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_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.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) module airflow.providers.openlineage 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.utils airflow.providers.openlineage.utils.selective_enable airflow.providers.openlineage.utils.spark airflow.providers.openlineage.utils.sql 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)

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)

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

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

S

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

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?