(airflow) branch main updated: fix: Get the pid of xcom command dynamically (#45053)

[js...@apache.org]

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

jscheffl 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 3c111680a83 fix: Get the pid of xcom command dynamically (#45053)
3c111680a83 is described below

commit 3c111680a837f22659555c9b6647df40d6ead5f0
Author: Laerte Pereira <58...@users.noreply.github.com>
AuthorDate: Wed Dec 18 18:46:19 2024 -0300

    fix: Get the pid of xcom command dynamically (#45053)
    
    * fix: Get the pid of xcom command dynamically
    
    * fix signal number
---
 providers/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/providers/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py b/providers/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py
index f7a602417b7..e65f0a63ae2 100644
--- a/providers/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py
+++ b/providers/src/airflow/providers/cncf/kubernetes/utils/pod_manager.py
@@ -855,7 +855,7 @@ class PodManager(LoggingMixin):
                 _preload_content=False,
             )
         ) as resp:
-            self._exec_pod_command(resp, "kill -2 1")
+            self._exec_pod_command(resp, "kill -2 $(pgrep -u $(whoami) -f trap)")
 
     def _exec_pod_command(self, resp, command: str) -> str | None:
         res = ""