airflow.providers.airbyte.sensors.airbyte

This module contains a Airbyte Job sensor.

Module Contents

Classes

AirbyteJobSensor

Check for the state of a previously submitted Airbyte job.
class airflow.providers.airbyte.sensors.airbyte.AirbyteJobSensor(*, airbyte_job_id, airbyte_conn_id='airbyte_default', api_version='v1', **kwargs)[source]

Bases: airflow.sensors.base.BaseSensorOperator

Check for the state of a previously submitted Airbyte job.

Parameters

  • airbyte_job_id (int) – Required. Id of the Airbyte job

  • airbyte_conn_id (str) – Optional. The name of the Airflow connection to get connection information for Airbyte. Defaults to “airbyte_default”.

  • api_version (str) – Optional. Airbyte API version. Defaults to “v1”.

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

Function defined by the sensors while deriving this class should override.

Was this entry helpful?