This is an automated email from the ASF dual-hosted git repository.
jscheffl 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 23cdb882dc8 Fix exceptions of positional session use in Edge provider
(2) (#67812)
23cdb882dc8 is described below
commit 23cdb882dc8289a220c31f1bb640f28a3d5553be
Author: Jens Scheffler <[email protected]>
AuthorDate: Mon Jun 1 18:55:10 2026 +0200
Fix exceptions of positional session use in Edge provider (2) (#67812)
---
providers/edge3/src/airflow/providers/edge3/executors/edge_executor.py | 3 +--
scripts/ci/prek/known_provide_session_positional.txt | 1 -
2 files changed, 1 insertion(+), 3 deletions(-)
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 dda48f49786..99d79ffb519 100644
--- a/providers/edge3/src/airflow/providers/edge3/executors/edge_executor.py
+++ b/providers/edge3/src/airflow/providers/edge3/executors/edge_executor.py
@@ -95,11 +95,10 @@ class EdgeExecutor(BaseExecutor):
self.edge_queued_tasks = deepcopy(self.queued_tasks)
super()._process_tasks(task_tuples) # type: ignore[misc]
- @provide_session
def queue_workload(
self,
workload: workloads.All,
- session: Session = NEW_SESSION,
+ session: Session,
) -> None:
"""Put new workload to queue. Airflow 3 entry point to execute a
task."""
if not isinstance(workload, workloads.ExecuteTask):
diff --git a/scripts/ci/prek/known_provide_session_positional.txt
b/scripts/ci/prek/known_provide_session_positional.txt
index 6ffd1b7cac0..7142b0362c5 100644
--- a/scripts/ci/prek/known_provide_session_positional.txt
+++ b/scripts/ci/prek/known_provide_session_positional.txt
@@ -9,4 +9,3 @@ airflow-core/src/airflow/models/team.py::1
airflow-core/src/airflow/models/trigger.py::7
airflow-core/src/airflow/models/variable.py::2
airflow-core/tests/unit/models/test_timestamp.py::2
-providers/edge3/src/airflow/providers/edge3/executors/edge_executor.py::1
