diff --git a/providers/edge3/src/airflow/providers/edge3/executors/edge_executor.py b/providers/edge3/src/airflow/providers/edge3/executors/edge_executor.py index 6bd216a918538..37659bfc17e14 100644 --- a/providers/edge3/src/airflow/providers/edge3/executors/edge_executor.py +++ b/providers/edge3/src/airflow/providers/edge3/executors/edge_executor.py @@ -113,7 +113,7 @@ def start(self, session: Session = NEW_SESSION): def _process_tasks(self, task_tuples: list[TaskTuple]) -> None: """ - Temponary overwrite of _process_tasks function. + Temporary overwrite of _process_tasks function. Idea is to not change the interface of the execute_async function in BaseExecutor as it will be changed in Airflow 3. Edge worker needs task_instance in execute_async but BaseExecutor deletes this out of the self.queued_tasks. @@ -132,7 +132,7 @@ def execute_async( session: Session = NEW_SESSION, ) -> None: """Execute asynchronously. Airflow 2.10 entry point to execute a task.""" - # Use of a temponary trick to get task instance, will be changed with Airflow 3.0.0 + # Use of a temporary trick to get task instance, will be changed with Airflow 3.0.0 # code works together with _process_tasks overwrite to get task instance. # TaskInstance in fourth element task_instance = self.edge_queued_tasks[key][3] # type: ignore[index] diff --git a/providers/edge3/src/airflow/providers/edge3/plugins/edge_executor_plugin.py b/providers/edge3/src/airflow/providers/edge3/plugins/edge_executor_plugin.py index d48bc8d5744be..9c8b32eadea33 100644 --- a/providers/edge3/src/airflow/providers/edge3/plugins/edge_executor_plugin.py +++ b/providers/edge3/src/airflow/providers/edge3/plugins/edge_executor_plugin.py @@ -53,7 +53,7 @@ def _get_api_endpoint(session: Session = NEW_SESSION) -> dict[str, Any]: } else: - # This is for back-compatability with Airflow 2.x and we only make this + # This is for back-compatibility with Airflow 2.x and we only make this # to prevents dependencies and breaking imports in Airflow 3.x import re from datetime import datetime, timedelta diff --git a/providers/edge3/src/airflow/providers/edge3/worker_api/routes/_v2_compat.py b/providers/edge3/src/airflow/providers/edge3/worker_api/routes/_v2_compat.py index be548d17a1459..2da0f0e23facc 100644 --- a/providers/edge3/src/airflow/providers/edge3/worker_api/routes/_v2_compat.py +++ b/providers/edge3/src/airflow/providers/edge3/worker_api/routes/_v2_compat.py @@ -34,7 +34,7 @@ def parse_command(command: str) -> ExecuteTask: return ExecuteTask.model_validate_json(command) else: - # Mock the external dependnecies + # Mock the external dependencies from typing import Callable from connexion import ProblemException