fix: Get the pid of xcom command dynamically (apache#45053)

* fix: Get the pid of xcom command dynamically * fix signal number
aws-mwaa · Dec 18, 2024 · 3c11168 · 3c11168
1 parent 2f92f82
commit 3c11168
Showing 1 changed file with 1 addition and 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
@@ -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 = ""