theesen commented on PR #21092: URL: https://github.com/apache/airflow/pull/21092#issuecomment-1622218297
Hey, yeah the author of the commit linked, refactored the sequence a bit and moved the call of `delete_custom_object` into the on_kill method. Which is ok in failure cases but does not solve the original intention of my implementation. Which was removing previous runs with the exact same time. Fixing this again should be easy though. `self.hook.delete_custom_object` needs to be called in the execute block again. Initially the approach was just to try to delete a spark app with that name, and catch the exception, if it does not exist as an expected case. -- 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]
