dheerajturaga commented on code in PR #57459:
URL: https://github.com/apache/airflow/pull/57459#discussion_r2471607873
##########
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:
@kaxil, this is the error I see in 3.1.0
```
Could not create GitHook bundle_name=airflow_dags version=None
bare_repo_path=PosixPath('/tmp/airflow/dag_bundles/airflow_dags/bare')
repo_path=PosixPath('/tmp/airflow/dag_bundles/airflow_dags/tracking_repo')
versions_path=PosixPath('/tmp/airflow/dag_bundles/airflow_dags/versions')
git_conn_id=airflow_dags conn_id=airflow_dags exc=ImportError("cannot import
name 'SUPERVISOR_COMMS'
from 'airflow.sdk.execution_time.task_runner'
(/home/airflow/.local/lib/python3.12/site-packages/airflow/sdk/execution_time/task_runner.py)")
```
This is the error I see in 3.1.1
```
Traceback (most recent call last):
File "/files/dags/test_connection_production.py", line 145, in
test_connection_retrieval
connection = GitHook.get_connection(conn_id)
File "/opt/airflow/task-sdk/src/airflow/sdk/bases/hook.py", line 61, in
get_connection
conn = Connection.get(conn_id)
File "/opt/airflow/task-sdk/src/airflow/sdk/definitions/connection.py",
line 225, in get
return _get_connection(conn_id)
File "/opt/airflow/task-sdk/src/airflow/sdk/execution_time/context.py",
line 175, in _get_connection
raise AirflowNotFoundException(f"The conn_id `{conn_id}` isn't defined")
airflow.exceptions.AirflowNotFoundException: The conn_id `airflow_dags`
isn't defined
```
This broke in 3.1.0 but I bypassed the issue by specifying the repo_url
through `dag_bundle_config_list`
--
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]
