airflow.providers.informatica.lineage.selective

Functions

disable_informatica_lineage(obj)

Mark a task (or all tasks in a DAG) to skip automatic lineage detection.

enable_informatica_lineage(obj)

Re-enable automatic lineage detection on a task (or all tasks in a DAG).

is_task_auto_lineage_disabled(task)

Return True when auto lineage has been explicitly disabled on this task.

Module Contents

airflow.providers.informatica.lineage.selective.disable_informatica_lineage(obj)[source]

Mark a task (or all tasks in a DAG) to skip automatic lineage detection.

Has no effect on manually declared inlets and outlets.

airflow.providers.informatica.lineage.selective.enable_informatica_lineage(obj)[source]

Re-enable automatic lineage detection on a task (or all tasks in a DAG).

Only needed to reverse a prior disable_informatica_lineage call.

airflow.providers.informatica.lineage.selective.is_task_auto_lineage_disabled(task)[source]

Return True when auto lineage has been explicitly disabled on this task.

Was this entry helpful?