airflow.providers.airbyte.hooks.airbyte
¶
Module Contents¶
-
class
airflow.providers.airbyte.hooks.airbyte.
AirbyteHook
(airbyte_conn_id: str = 'airbyte_default', api_version: Optional[str] = 'v1')[source]¶ Bases:
airflow.providers.http.hooks.http.HttpHook
Hook for Airbyte API
- Parameters
-
wait_for_job
(self, job_id: str, wait_seconds: Optional[float] = 3, timeout: Optional[float] = 3600)[source]¶ Helper method which polls a job to check if it finishes.