airflow.providers.airbyte.sensors.airbyte

This module contains a Airbyte Job sensor.

Module Contents

class airflow.providers.airbyte.sensors.airbyte.AirbyteJobSensor(*, airbyte_job_id: str, airbyte_conn_id: str = 'airbyte_default', api_version: Optional[str] = 'v1', **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

Check for the state of a previously submitted Airbyte job.

Parameters

  • airbyte_job_id (str) -- Required. Id of the Airbyte job

  • airbyte_conn_id (str) -- Required. The name of the Airflow connection to get connection information for Airbyte.

  • api_version (str) -- Optional. Airbyte API version.

template_fields = ['airbyte_job_id'][source]
ui_color = #6C51FD[source]
poke(self, context: dict)[source]

Was this entry helpful?