This is an automated email from the ASF dual-hosted git repository.
eladkal pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new b48280c053 Applied D401 to airbyte files. (#37370)
b48280c053 is described below
commit b48280c0530de1dafd9fcf428f3ce6264fcbdc97
Author: Satoshi S <[email protected]>
AuthorDate: Mon Feb 12 21:51:29 2024 -0600
Applied D401 to airbyte files. (#37370)
---
airflow/providers/airbyte/hooks/airbyte.py | 4 ++--
airflow/providers/airbyte/operators/airbyte.py | 2 +-
airflow/providers/airbyte/sensors/airbyte.py | 4 ++--
airflow/providers/airbyte/triggers/airbyte.py | 2 +-
pyproject.toml | 4 ----
5 files changed, 6 insertions(+), 10 deletions(-)
diff --git a/airflow/providers/airbyte/hooks/airbyte.py
b/airflow/providers/airbyte/hooks/airbyte.py
index b8ad957a9c..4545eeb7ba 100644
--- a/airflow/providers/airbyte/hooks/airbyte.py
+++ b/airflow/providers/airbyte/hooks/airbyte.py
@@ -79,7 +79,7 @@ class AirbyteHook(HttpHook):
async def get_job_details(self, job_id: int) -> Any:
"""
- Uses Http async call to retrieve metadata for a specific job of an
Airbyte Sync.
+ Use Http async call to retrieve metadata for a specific job of an
Airbyte Sync.
:param job_id: The ID of an Airbyte Sync Job.
"""
@@ -97,7 +97,7 @@ class AirbyteHook(HttpHook):
async def get_job_status(self, job_id: int) -> str:
"""
- Retrieves the status for a specific job of an Airbyte Sync.
+ Retrieve the status for a specific job of an Airbyte Sync.
:param job_id: The ID of an Airbyte Sync Job.
"""
diff --git a/airflow/providers/airbyte/operators/airbyte.py
b/airflow/providers/airbyte/operators/airbyte.py
index 84a12dadfa..d8fdddb0e2 100644
--- a/airflow/providers/airbyte/operators/airbyte.py
+++ b/airflow/providers/airbyte/operators/airbyte.py
@@ -115,7 +115,7 @@ class AirbyteTriggerSyncOperator(BaseOperator):
def execute_complete(self, context: Context, event: Any = None) -> None:
"""
- Callback for when the trigger fires - returns immediately.
+ Invoke this callback when the trigger fires; return immediately.
Relies on trigger to throw an exception, otherwise it assumes
execution was
successful.
diff --git a/airflow/providers/airbyte/sensors/airbyte.py
b/airflow/providers/airbyte/sensors/airbyte.py
index 4556d55430..4cc280cfc4 100644
--- a/airflow/providers/airbyte/sensors/airbyte.py
+++ b/airflow/providers/airbyte/sensors/airbyte.py
@@ -105,7 +105,7 @@ class AirbyteJobSensor(BaseSensorOperator):
return False
def execute(self, context: Context) -> Any:
- """Submits a job which generates a run_id and gets deferred."""
+ """Submit a job which generates a run_id and gets deferred."""
if not self.deferrable:
super().execute(context)
else:
@@ -139,7 +139,7 @@ class AirbyteJobSensor(BaseSensorOperator):
def execute_complete(self, context: Context, event: Any = None) -> None:
"""
- Callback for when the trigger fires - returns immediately.
+ Invoke this callback when the trigger fires; return immediately.
Relies on trigger to throw an exception, otherwise it assumes
execution was
successful.
diff --git a/airflow/providers/airbyte/triggers/airbyte.py
b/airflow/providers/airbyte/triggers/airbyte.py
index 06c926d681..cec032a5e0 100644
--- a/airflow/providers/airbyte/triggers/airbyte.py
+++ b/airflow/providers/airbyte/triggers/airbyte.py
@@ -51,7 +51,7 @@ class AirbyteSyncTrigger(BaseTrigger):
self.poll_interval = poll_interval
def serialize(self) -> tuple[str, dict[str, Any]]:
- """Serializes AirbyteSyncTrigger arguments and classpath."""
+ """Serialize AirbyteSyncTrigger arguments and classpath."""
return (
"airflow.providers.airbyte.triggers.airbyte.AirbyteSyncTrigger",
{
diff --git a/pyproject.toml b/pyproject.toml
index 175de74913..481f04af43 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -1370,10 +1370,6 @@ combine-as-imports = true
"tests/providers/qdrant/operators/test_qdrant.py" = ["E402"]
# All the modules which do not follow D401 yet, please remove as soon as it
becomes compatible
-"airflow/providers/airbyte/hooks/airbyte.py" = ["D401"]
-"airflow/providers/airbyte/operators/airbyte.py" = ["D401"]
-"airflow/providers/airbyte/sensors/airbyte.py" = ["D401"]
-"airflow/providers/airbyte/triggers/airbyte.py" = ["D401"]
"airflow/providers/common/io/xcom/backend.py" = ["D401"]
"airflow/providers/databricks/hooks/databricks.py" = ["D401"]
"airflow/providers/databricks/operators/databricks.py" = ["D401"]
