airflow.providers.informatica.lineage.resolver¶

Attributes¶

`BaseLineageResolver`	Base class for operator lineage resolvers.
`SQLLineageResolver`	Resolves lineage for any operator that exposes a `sql` attribute.

Return a resolver for task, or None when no resolver applies.

class airflow.providers.informatica.lineage.resolver.BaseLineageResolver[source]¶

Base class for operator lineage resolvers.

abstract resolve(task)[source]¶

Return (source_refs, target_refs) or None if the resolver does not apply.

class airflow.providers.informatica.lineage.resolver.SQLLineageResolver[source]¶

Resolves lineage for any operator that exposes a sql attribute.

Detection is tiered:

Tier 1: operators inheriting from BaseSQLOperator — conn_id_field points to the right connection attribute.
Tier 2: operators with a sql attribute but no BaseSQLOperator base (e.g. GenericTransfer, BaseSQLToGCSOperator) — dialect is inferred from the first recognizable connection ID string found.

Returns None when there is no SQL, when Jinja templates are detected, or when parsing produces no table references.

resolve(task)[source]¶

Return (source_refs, target_refs) or None if the resolver does not apply.

airflow.providers.informatica.lineage.resolver.get_resolver(task)[source]¶

Return a resolver for task, or None when no resolver applies.