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) -- Required. The name of the Airflow connection to get connection information for Airbyte.

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

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

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

Was this entry helpful?