uranusjr commented on code in PR #57472:
URL: https://github.com/apache/airflow/pull/57472#discussion_r2472221012
##########
providers/standard/src/airflow/providers/standard/utils/python_virtualenv_script.jinja2:
##########
@@ -47,7 +47,15 @@ else:
{#- We are in an Airflow 3.x env, try and set up supervisor comms so virtual
env can still access tasks etc! #}
reinit_supervisor_comms = getattr(task_runner, "reinit_supervisor_comms",
None)
if reinit_supervisor_comms:
- reinit_supervisor_comms()
+ try:
+ reinit_supervisor_comms()
+ except OSError as e:
+ if e.errno == 88: # Socket operation on non-socket
+ # In subprocess environments (like PythonVirtualenvOperator),
stdin may not be a socket
+ # This is expected behavior, supervisor communication is not
available
Review Comment:
What happens when the subprocess cannot talk to the supervisor? Are there
certain things it won’t be able to do?
--
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]
