@hussein-awala Was this introduced back? Or is this termination problem still happening in newest versions?

Was this introduced back? Or is this termination problem still happening in newest versions?

The fix was released in cncf.kubernetes 7.3.0 (changelog), are you facing the same problem in a newer version?

I meant the opposite.
In 7.2.0 KPO works fine, but in 7.3.0 it is not.
We suspect that this is due to removing following part of code:

if pod_status not in PodPhase.terminal_states:
    self.log.info(
        "Pod %s is still running. Sleeping for %s seconds.",
        self.pod_name,
        self.poll_interval,
    )
    await asyncio.sleep(self.poll_interval)

How do you feel, can this be reintroduced? Or was this solved in never version differently?
When we had high load of KPO they started to fail from Airflow perspective, while those pods were started properly.

In our case we didn't use do_xcom_push, so it wasn't a problem for us.
We were wondering, if it might be reimplemented to include changes from #31348 properly.