From afb850ff63136a9aa70244e886dbd11c00e611f2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?T=C3=BAlio=20Lima?= Date: Wed, 19 Feb 2025 10:27:00 -0300 Subject: [PATCH 1/4] fix(airbyte): fixing some mistakes in AirbyteJobSensor docs. --- providers/src/airflow/providers/airbyte/sensors/airbyte.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/providers/src/airflow/providers/airbyte/sensors/airbyte.py b/providers/src/airflow/providers/airbyte/sensors/airbyte.py index bb524fc322598..9a3d2d49f228c 100644 --- a/providers/src/airflow/providers/airbyte/sensors/airbyte.py +++ b/providers/src/airflow/providers/airbyte/sensors/airbyte.py @@ -39,10 +39,11 @@ class AirbyteJobSensor(BaseSensorOperator): """ Check for the state of a previously submitted Airbyte job. - :param airbyte_job_id: Required. Id of the Airbyte job + :param airbyte_job_id: Required. Id of the Airbyte job. :param airbyte_conn_id: Optional. The name of the Airflow connection to get - :param deferrable: Run sensor in the deferrable mode. connection information for Airbyte. Defaults to "airbyte_default". + :param deferrable: Optional. Runs the sensor in deferrable mode. + Defaults to the config value "default_deferrable" or False, if not defined. :param api_version: Optional. Airbyte API version. Defaults to "v1". """ From a76ec7e458ac6a14507cdc84e83689a9066ba4bc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?T=C3=BAlio=20Lima?= Date: Sun, 13 Apr 2025 18:36:24 -0300 Subject: [PATCH 2/4] fix: reduce line length --- providers/src/airflow/providers/airbyte/sensors/airbyte.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/providers/src/airflow/providers/airbyte/sensors/airbyte.py b/providers/src/airflow/providers/airbyte/sensors/airbyte.py index 9a3d2d49f228c..4afccceabdf42 100644 --- a/providers/src/airflow/providers/airbyte/sensors/airbyte.py +++ b/providers/src/airflow/providers/airbyte/sensors/airbyte.py @@ -42,8 +42,8 @@ class AirbyteJobSensor(BaseSensorOperator): :param airbyte_job_id: Required. Id of the Airbyte job. :param airbyte_conn_id: Optional. The name of the Airflow connection to get connection information for Airbyte. Defaults to "airbyte_default". - :param deferrable: Optional. Runs the sensor in deferrable mode. - Defaults to the config value "default_deferrable" or False, if not defined. + :param deferrable: Optional. Runs the sensor in deferrable mode. Defaults + to the config value "default_deferrable" or False, if not defined. :param api_version: Optional. Airbyte API version. Defaults to "v1". """ From 925d39272b956adaba739bf5d66da8f18d2ef2b1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?T=C3=BAlio=20Lima?= Date: Wed, 19 Feb 2025 10:27:00 -0300 Subject: [PATCH 3/4] fix(airbyte): fixing some mistakes in AirbyteJobSensor docs. --- .../airbyte/src/airflow/providers/airbyte/sensors/airbyte.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/providers/airbyte/src/airflow/providers/airbyte/sensors/airbyte.py b/providers/airbyte/src/airflow/providers/airbyte/sensors/airbyte.py index bb524fc322598..9a3d2d49f228c 100644 --- a/providers/airbyte/src/airflow/providers/airbyte/sensors/airbyte.py +++ b/providers/airbyte/src/airflow/providers/airbyte/sensors/airbyte.py @@ -39,10 +39,11 @@ class AirbyteJobSensor(BaseSensorOperator): """ Check for the state of a previously submitted Airbyte job. - :param airbyte_job_id: Required. Id of the Airbyte job + :param airbyte_job_id: Required. Id of the Airbyte job. :param airbyte_conn_id: Optional. The name of the Airflow connection to get - :param deferrable: Run sensor in the deferrable mode. connection information for Airbyte. Defaults to "airbyte_default". + :param deferrable: Optional. Runs the sensor in deferrable mode. + Defaults to the config value "default_deferrable" or False, if not defined. :param api_version: Optional. Airbyte API version. Defaults to "v1". """ From f1be7983047a7ed12f63492f4a3b3e22b11b9ba1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?T=C3=BAlio=20Lima?= Date: Sun, 13 Apr 2025 18:36:24 -0300 Subject: [PATCH 4/4] fix: reduce line length --- .../airbyte/src/airflow/providers/airbyte/sensors/airbyte.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/providers/airbyte/src/airflow/providers/airbyte/sensors/airbyte.py b/providers/airbyte/src/airflow/providers/airbyte/sensors/airbyte.py index 9a3d2d49f228c..4afccceabdf42 100644 --- a/providers/airbyte/src/airflow/providers/airbyte/sensors/airbyte.py +++ b/providers/airbyte/src/airflow/providers/airbyte/sensors/airbyte.py @@ -42,8 +42,8 @@ class AirbyteJobSensor(BaseSensorOperator): :param airbyte_job_id: Required. Id of the Airbyte job. :param airbyte_conn_id: Optional. The name of the Airflow connection to get connection information for Airbyte. Defaults to "airbyte_default". - :param deferrable: Optional. Runs the sensor in deferrable mode. - Defaults to the config value "default_deferrable" or False, if not defined. + :param deferrable: Optional. Runs the sensor in deferrable mode. Defaults + to the config value "default_deferrable" or False, if not defined. :param api_version: Optional. Airbyte API version. Defaults to "v1". """