fix: compute.cancel_executions

- fixed one bug in compute.cancel_executions
- Execution is unusable outside of our codebase,
removed from export and refactored arguments in cancel_executions

risk: low

Author: fiedlr

gooddata-sdk/gooddata_sdk/__init__.py

@@ -231,7 +231,6 @@
 from gooddata_sdk.compute.model.base import ExecModelEntity, ObjId
 from gooddata_sdk.compute.model.execution import (
     BareExecutionResponse,
-    Execution,
     ExecutionDefinition,
     ExecutionResponse,
     ExecutionResult,

gooddata-sdk/gooddata_sdk/compute/service.py

@@ -112,23 +112,25 @@ def ai_chat_history_reset(self, workspace_id: str) -> None:
         chat_history_request = ChatHistoryRequest(reset=True)
         self._actions_api.ai_chat_history(workspace_id, chat_history_request, _check_return_type=False)
 
-    def cancel_executions(self, executions: list[Execution]) -> None:
+    def cancel_executions(self, executions: list[tuple[str, str]]) -> None:
         """
         Try to cancel given executions using the cancel api endpoint.
+        Order of token applications is not guaranteed.
 
         *Note that this is currently a noop, we will be enabling this functionality soon.*
 
         Args:
-            executions: list of executions to send for cancellation
+            executions: list of tuples [workspace_id, cancel_token] to send for cancellation
         """
         workspace_to_tokens: dict[str, set[str]] = {}
 
         for execution in executions:
-            if not workspace_to_tokens[execution.workspace_id]:
-                workspace_to_tokens[execution.workspace_id] = set()
+            workspace_id, cancel_token = execution
 
-            if execution.cancel_token:
-                workspace_to_tokens[execution.workspace_id].add(execution.cancel_token)
+            if workspace_id not in workspace_to_tokens:
+                workspace_to_tokens[workspace_id] = set()
+
+            workspace_to_tokens[workspace_id].add(cancel_token)
 
         for workspace_id, token_ids in workspace_to_tokens.items():
             self._actions_api.cancel_executions(workspace_id, AfmCancelTokens(list(token_ids)))