Sanjays2402 commented on PR #73709: URL: https://github.com/apache/airflow/pull/73709#issuecomment-5975217446
Good catch, thanks @rjgoyln! I've applied your suggestion: the two pod API calls are now wrapped in a try/except that restores the key to self.running and re-raises, so when sync() re-queues a result after a failed delete_pod (e.g. a 429 or 5xx), the retry isn't mistaken for a duplicate completion. The duplicate-event dedup behavior is unchanged, and the adopt-completed-pods path is untouched per your snippet. The new tests and the rest of the executors suite stay green locally. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
