airflow.providers.informatica.extractors.informatica

Classes

InformaticaLineageExtractor

Extracts lineage information from Informatica EDC and converts to Airflow Assets.

Module Contents

class airflow.providers.informatica.extractors.informatica.InformaticaLineageExtractor(edc_hook)[source]

Bases: airflow.utils.log.logging_mixin.LoggingMixin

Extracts lineage information from Informatica EDC and converts to Airflow Assets.

edc_hook[source]
get_object(object_id)[source]

Return Informatica catalog object by id via EDC hook.

Args:

object_id (str): Informatica object id.

Returns:

dict[str, Any]: Informatica catalog object.

Create a lineage link between source and target objects via EDC hook.

Args:

source_object_id (str): Source Informatica object id. target_object_id (str): Target Informatica object id.

Returns:

dict[str, Any]: Result of lineage link creation.

Was this entry helpful?