kaxil commented on code in PR #57459:
URL: https://github.com/apache/airflow/pull/57459#discussion_r2479545820
##########
airflow-core/src/airflow/jobs/dag_processor_job_runner.py:
##########
@@ -56,6 +57,9 @@ def __init__(
)
def _execute(self) -> int | None:
+ # Mark this as a server context for secrets backend detection
+ os.environ["_AIRFLOW_PROCESS_CONTEXT"] = "server"
+
Review Comment:
The problem with this env var is also that the child processes will inherit
the env var.
While not a problem in itself, since `if hasattr(task_runner,
"SUPERVISOR_COMMS") and task_runner.SUPERVISOR_COMMS is not None:` is checked
first, but for correctness it shouldn't be there.
Let me take a stab at it with a PR
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
