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 229750d8bb8 Fix EdgeExecutor breeze call (#43842)
229750d8bb8 is described below
commit 229750d8bb85b98eb45ba063e9ae1d5a62aaeb84
Author: Jens Scheffler <[email protected]>
AuthorDate: Sat Nov 9 17:58:18 2024 +0100
Fix EdgeExecutor breeze call (#43842)
---
dev/breeze/src/airflow_breeze/params/shell_params.py | 3 +++
1 file changed, 3 insertions(+)
diff --git a/dev/breeze/src/airflow_breeze/params/shell_params.py
b/dev/breeze/src/airflow_breeze/params/shell_params.py
index 0c602643751..f37e5b21d6d 100644
--- a/dev/breeze/src/airflow_breeze/params/shell_params.py
+++ b/dev/breeze/src/airflow_breeze/params/shell_params.py
@@ -497,6 +497,9 @@ class ShellParams:
_set_var(_env, "AIRFLOW__CELERY__BROKER_URL",
self.airflow_celery_broker_url)
_set_var(_env, "AIRFLOW__CORE__EXECUTOR", self.executor)
if self.executor == EDGE_EXECUTOR:
+ _set_var(
+ _env, "AIRFLOW__CORE__EXECUTOR",
"airflow.providers.edge.executors.edge_executor.EdgeExecutor"
+ )
_set_var(_env, "AIRFLOW__EDGE__API_ENABLED", "true")
_set_var(_env, "AIRFLOW__EDGE__API_URL",
"http://localhost:8080/edge_worker/v1/rpcapi";)
_set_var(_env, "ANSWER", get_forced_answer() or "")
