Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -268,7 +268,6 @@ def execute(self, context: Context):
Lake, effectively creates the compute cluster.
Airflow runs this method on the worker and defers using the trigger.
"""
super().execute(context)
return self._compute_cluster_execute()

def _compute_cluster_execute(self):
Expand Down Expand Up @@ -356,7 +355,6 @@ def execute(self, context: Context):
Lake, effectively drops the compute cluster.
Airflow runs this method on the worker and defers using the trigger.
"""
super().execute(context)
return self._compute_cluster_execute()

def _compute_cluster_execute(self):
Expand Down Expand Up @@ -417,7 +415,6 @@ def execute(self, context: Context):
Lake, effectively resumes the compute cluster.
Airflow runs this method on the worker and defers using the trigger.
"""
super().execute(context)
return self._compute_cluster_execute()

def _compute_cluster_execute(self):
Expand Down Expand Up @@ -488,7 +485,6 @@ def execute(self, context: Context):
Lake, effectively suspends the compute cluster.
Airflow runs this method on the worker and defers using the trigger.
"""
super().execute(context)
return self._compute_cluster_execute()

def _compute_cluster_execute(self):
Expand Down