From 3c111680a837f22659555c9b6647df40d6ead5f0 Mon Sep 17 00:00:00 2001
From: Laerte Pereira <5853172+Laerte@users.noreply.github.com>
Date: Wed, 18 Dec 2024 18:46:19 -0300
Subject: [PATCH] fix: Get the pid of xcom command dynamically (#45053)

* fix: Get the pid of xcom command dynamically

* fix signal number
---
 .../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 f7a602417b7fc..e65f0a63ae28b 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 @@ def extract_xcom_kill(self, pod: V1Pod):
                 _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 = ""