Re: [I] Couldn't able to access Airflow variables inside @task.virtualenv operator [airflow]

["amordoch (via GitHub)" <gi...@apache.org>]

amordoch commented on issue #51422:
URL: https://github.com/apache/airflow/issues/51422#issuecomment-3365922353

   I get a similar error attempting to fetch a connection, but the actual error matches #51816.
   
   ```log
   INFO - Executing cmd: /tmp/venvgytrxbba/bin/python /tmp/venv-calluauhrpy3/script.py /tmp/venv-calluauhrpy3/script.in /tmp/venv-calluauhrpy3/script.out /tmp/venv-calluauhrpy3/string_args.txt /tmp/venv-calluauhrpy3/termination.log /tmp/venv-calluauhrpy3/airflow_context.json source=airflow.utils.process_utils loc=process_utils.py:188
   INFO - Output: source=airflow.utils.process_utils loc=process_utils.py:192
   INFO - /tmp/venvgytrxbba/lib/python3.12/site-packages/airflow/configuration.py:814 DeprecationWarning: The grid_view_sorting_order option in [webserver] has been moved to the grid_view_sorting_order option in [api] - the old setting has been used, but please update your config. source=airflow.utils.process_utils loc=process_utils.py:196
   INFO - /tmp/venvgytrxbba/lib/python3.12/site-packages/airflow/configuration.py:815 DeprecationWarning: The grid_view_sorting_order option in [webserver] has been moved to the grid_view_sorting_order option in [api] - the old setting has been used, but please update your config. source=airflow.utils.process_utils loc=process_utils.py:196
   INFO - Traceback (most recent call last): source=airflow.utils.process_utils loc=process_utils.py:196
   INFO -   File "/tmp/venv-calluauhrpy3/script.py", line 89, in <module> source=airflow.utils.process_utils loc=process_utils.py:196
   INFO -     res = influx_write(*arg_dict["args"], **arg_dict["kwargs"]) source=airflow.utils.process_utils loc=process_utils.py:196
   INFO -           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ source=airflow.utils.process_utils loc=process_utils.py:196
   INFO -   File "/tmp/venv-calluauhrpy3/script.py", line 44, in influx_write source=airflow.utils.process_utils loc=process_utils.py:196
   INFO -     conn: Connection = Connection.get(conn_id) source=airflow.utils.process_utils loc=process_utils.py:196
   INFO -                        ^^^^^^^^^^^^^^^^^^^^^^^ source=airflow.utils.process_utils loc=process_utils.py:196
   INFO -   File "/tmp/venvgytrxbba/lib/python3.12/site-packages/airflow/sdk/definitions/connection.py", line 226, in get source=airflow.utils.process_utils loc=process_utils.py:196
   INFO -     return _get_connection(conn_id) source=airflow.utils.process_utils loc=process_utils.py:196
   INFO -            ^^^^^^^^^^^^^^^^^^^^^^^^ source=airflow.utils.process_utils loc=process_utils.py:196
   INFO -   File "/tmp/venvgytrxbba/lib/python3.12/site-packages/airflow/sdk/execution_time/context.py", line 181, in _get_connection source=airflow.utils.process_utils loc=process_utils.py:196
   INFO -     from airflow.sdk.execution_time.task_runner import SUPERVISOR_COMMS source=airflow.utils.process_utils loc=process_utils.py:196
   INFO - ImportError: cannot import name 'SUPERVISOR_COMMS' from 'airflow.sdk.execution_time.task_runner' (/tmp/venvgytrxbba/lib/python3.12/site-packages/airflow/sdk/execution_time/task_runner.py) source=airflow.utils.process_utils loc=process_utils.py:196
   ```


-- 
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: commits-unsubscribe@airflow.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org