module ingestion_pipeline_mixin

Mixin class containing ingestion pipeline specific methods

To be used by OpenMetadata class

class OMetaIngestionPipelineMixin

OpenMetadata API methods related to ingestion pipeline.

To be inherited by OpenMetadata

method create_or_update_pipeline_status

PUT create or update pipeline status

:param ingestion_pipeline_fqn: Ingestion Pipeline FQN :param pipeline_status: Pipeline Status data to add

method get_ingestion_pipeline_by_name

Get ingestion pipeline statues based on name

Args:

• <b>name</b> (str): Ingestion Pipeline Name
• <b>fields</b> (List[str]): List of all the fields

method get_pipeline_status

GET pipeline status

:param ingestion_pipeline_fqn: Ingestion Pipeline FQN :param pipeline_status_run_id: Pipeline Status run id

method get_pipeline_status_between_ts

Get pipeline status between timestamp

Args:

• <b>ingestion_pipeline_fqn</b> (str): pipeline fqn
• <b>start_ts</b> (int): start_ts
• <b>end_ts</b> (int): end_ts

method run_pipeline

Run ingestion pipeline workflow

Args:

• <b>ingestion_pipeline_id</b> (str): ingestion pipeline uuid