adrian-edbert commented on issue #57336: URL: https://github.com/apache/airflow/issues/57336#issuecomment-3455066513
the last configuration I pass is using the pypi package without involving my fork I have also tried using the newly published 3.1.1 pypi package, but now I got different error which basically just mention the connection can't be found ``` [2025-10-28 14:31:37] ERROR - Task failed with exception source=task loc=task_runner.py:972 AirflowNotFoundException: The conn_id `worker_connection_env` isn't defined File "/home/generic_scheduler/test_airflow/test-venv/lib/python3.12/site-packages/airflow/sdk/execution_time/task_runner.py", line 920 in run File "/home/generic_scheduler/test_airflow/test-venv/lib/python3.12/site-packages/airflow/sdk/execution_time/task_runner.py", line 1307 in _execute_task File "/home/generic_scheduler/test_airflow/test-venv/lib/python3.12/site-packages/airflow/sdk/bases/operator.py", line 416 in wrapper File "/home/generic_scheduler/test_airflow/test-venv/lib/python3.12/site-packages/airflow/providers/standard/operators/python.py", line 216 in execute File "/home/generic_scheduler/test_airflow/test-venv/lib/python3.12/site-packages/airflow/providers/standard/operators/python.py", line 239 in execute_callable File "/home/generic_scheduler/test_airflow/test-venv/lib/python3.12/site-packages/airflow/sdk/execution_time/callback_runner.py", line 82 in run File "/home/generic_scheduler/test_airflow/dag-bundles/...../versions/...../dags/test_dag.py", line 25 in print_env File "/home/generic_scheduler/test_airflow/test-venv/lib/python3.12/site-packages/airflow/sdk/bases/hook.py", line 61 in get_connection File "/home/generic_scheduler/test_airflow/test-venv/lib/python3.12/site-packages/airflow/sdk/definitions/connection.py", line 225 in get File "/home/generic_scheduler/test_airflow/test-venv/lib/python3.12/site-packages/airflow/sdk/execution_time/context.py", line 172 in _get_connection ``` for now since it seems to be working from your side, I'll try to check if there's any changes from my fork that initialize `DagVersion` or something similar along the celery worker, that seems to be the things that differ in my envs -- 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]
