The GitHub Actions job "Tests AMD" on airflow.git/supervisorcomms-in-venv-subprocesses has failed. Run started by GitHub user ashb (triggered by ashb).
Head commit for run: 7292ac56710545e65f602f92c48697e591955613 / Ash Berlin-Taylor <[email protected]> Add support for "reconnecting" Supervisor Comms and logs in task processes This change relates to #51422, #54706 and gives us a single function that we can call from the Python Virtual env script to re-connect the SUPERVISOR_COMMS and logs socket, so variables and connections are accessible from within the VEnv task, as long as task-sdk is installed. This also fixes logs produced by a venv task to not be double "encoded" (i.e. so that we directly see the actual log, not a stringification of the entire log line with two timestamps etc.) There is a matching change to the Venv script to use this function, but it is separated into a different PR so that we don't merge core/sdk and provider changes in one PR. The crux of the change in the venv operator (that I've already tested) is this ```diff +try: + from airflow.sdk.execution_time import task_runner +except ModuleNotFoundError: + pass +else: + reinit_supervisor_comms = getattr(task_runner, "reinit_supervisor_comms") + if reinit_supervisor_comms: + reinit_supervisor_comms() ``` Report URL: https://github.com/apache/airflow/actions/runs/18792456257 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
