Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand All @@ -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]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Loading