[GitHub] [airflow] dirrao commented on pull request #32249: Schedulers are issuing abrupt pod deletes when there is a delay in schedulers' heartbeat

dirrao commented on PR #32249: URL: https://github.com/apache/airflow/pull/32249#issuecomment-1638445760 @hussein-awala I have rebased the code with main branch and added unit test cases. Can you review it? -- This is an automated message from the Apache Git Service. To respond to th

[GitHub] [airflow] dirrao commented on pull request #32249: Schedulers are issuing abrupt pod deletes when there is a delay in schedulers' heartbeat

dirrao commented on PR #32249: URL: https://github.com/apache/airflow/pull/32249#issuecomment-1636640787 @hussein-awala Thanks for sharing the example. The reason for this issue is schedulers are subscribed to their worker pod events based on the scheduler id label filter i.e. ( kwargs

[GitHub] [airflow] dirrao commented on pull request #32249: Schedulers are issuing abrupt pod deletes when there is a delay in schedulers' heartbeat

dirrao commented on PR #32249: URL: https://github.com/apache/airflow/pull/32249#issuecomment-1614196394 Hi @dstandish, Problem: When scheduler creates a worker pod for the task, it attaches a label to the pod. This label is airflow-worker=. This label is a unique identifier