Refactor GKE hooks (#38404)

apache · Mar 25, 2024 · 32ed83b · 32ed83b
1 parent 44672c8
commit 32ed83b
Show file tree

Hide file tree

Showing 10 changed files with 174 additions and 314 deletions.
diff --git a/airflow/providers/cncf/kubernetes/operators/pod.py b/airflow/providers/cncf/kubernetes/operators/pod.py
@@ -771,7 +771,7 @@ def _clean(self, event: dict[str, Any]):
 
     @deprecated(reason="use `trigger_reentry` instead.", category=AirflowProviderDeprecationWarning)
     def execute_complete(self, context: Context, event: dict, **kwargs):
-        self.trigger_reentry(context=context, event=event)
+        return self.trigger_reentry(context=context, event=event)
 
     def write_logs(self, pod: k8s.V1Pod):
         try: