ashb commented on a change in pull request #10315:
URL: https://github.com/apache/airflow/pull/10315#discussion_r483567482
##########
File path: airflow/providers/cncf/kubernetes/operators/kubernetes_pod.py
##########
@@ -294,6 +299,10 @@ def execute(self, context) -> Optional[str]:
self.log.info("creating pod with labels %s and launcher %s",
labels, launcher)
final_state, _, result =
self.create_new_pod_for_operator(labels, launcher)
if final_state != State.SUCCESS:
+ if self.retry_only_on_pod_launching_failure:
Review comment:
Is there any other way this condition could be hit?
I'm just not 100% sure on the name for this setting -- I can see it useful
but (in my sleep deprived state) I'm struggling to parse the docs/name of the
param to work out what it actually does.
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
