(airflow) branch main updated: Add PID and return code to _execute_in_fork logging (#40058)

[uranusjr]

This is an automated email from the ASF dual-hosted git repository.

uranusjr pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 73d02e0f21 Add PID and return code to _execute_in_fork logging (#40058)
73d02e0f21 is described below

commit 73d02e0f219216910297548d6ec8bd13f523865c
Author: Wei Lee <weilee...@gmail.com>
AuthorDate: Wed Jun 5 15:19:37 2024 +0800

    Add PID and return code to _execute_in_fork logging (#40058)
---
 airflow/providers/celery/executors/celery_executor_utils.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/airflow/providers/celery/executors/celery_executor_utils.py 
b/airflow/providers/celery/executors/celery_executor_utils.py
index c5735394a3..48db3f14ae 100644
--- a/airflow/providers/celery/executors/celery_executor_utils.py
+++ b/airflow/providers/celery/executors/celery_executor_utils.py
@@ -147,7 +147,7 @@ def _execute_in_fork(command_to_exec: CommandType, 
celery_task_id: str | None =
         if ret == 0:
             return
 
-        msg = f"Celery command failed on host: {get_hostname()} with 
celery_task_id {celery_task_id}"
+        msg = f"Celery command failed on host: {get_hostname()} with 
celery_task_id {celery_task_id} (PID: {pid}, Return Code: {ret})"
         raise AirflowException(msg)
 
     from airflow.sentry import Sentry