Skip to content

Commit 32ed83b

Browse files
authored
Refactor GKE hooks (#38404)
1 parent 44672c8 commit 32ed83b

File tree

10 files changed

+174
-314
lines changed

10 files changed

+174
-314
lines changed

airflow/providers/cncf/kubernetes/operators/pod.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -771,7 +771,7 @@ def _clean(self, event: dict[str, Any]):
771771

772772
@deprecated(reason="use `trigger_reentry` instead.", category=AirflowProviderDeprecationWarning)
773773
def execute_complete(self, context: Context, event: dict, **kwargs):
774-
self.trigger_reentry(context=context, event=event)
774+
return self.trigger_reentry(context=context, event=event)
775775

776776
def write_logs(self, pod: k8s.V1Pod):
777777
try:

0 commit comments

Comments
 (0)