From 76f38cc58ed6d72b64a914ae0bbcb3af4134795a Mon Sep 17 00:00:00 2001 From: Jacob Zufelt Date: Fri, 16 Feb 2024 10:19:43 -0700 Subject: [PATCH 1/2] Add get_result method to st2client --- CHANGELOG.rst | 3 +++ st2client/st2client/models/core.py | 10 ++++++++++ 2 files changed, 13 insertions(+) diff --git a/CHANGELOG.rst b/CHANGELOG.rst index 1e48760eef..faa1628729 100644 --- a/CHANGELOG.rst +++ b/CHANGELOG.rst @@ -21,6 +21,9 @@ Added #6118 Contributed by @cognifloyd +* Added a `get_result` method to the `ExecutionResourceManager` Class for st2client + Contributed by @skiedude + 3.8.1 - December 13, 2023 ------------------------- Fixed diff --git a/st2client/st2client/models/core.py b/st2client/st2client/models/core.py index e66e0e7800..ab4b0e0aa9 100644 --- a/st2client/st2client/models/core.py +++ b/st2client/st2client/models/core.py @@ -547,6 +547,16 @@ def get_output(self, execution_id, output_type=None, **kwargs): return response.text + @add_auth_token_to_kwargs_from_env + def get_result(self, execution_id, **kwargs): + url = "/%s/%s/result" % (self.resource.get_url_path_name(), execution_id) + + response = self.client.get(url, **kwargs) + if response.status_code != http_client.OK: + self.handle_error(response) + + return orjson.loads(response.text) + @add_auth_token_to_kwargs_from_env def pause(self, execution_id, **kwargs): url = "/%s/%s" % (self.resource.get_url_path_name(), execution_id) From 4b99ed578956ec12072be84e8892ad930b1244d2 Mon Sep 17 00:00:00 2001 From: Jacob Zufelt Date: Mon, 26 Feb 2024 10:53:30 -0700 Subject: [PATCH 2/2] only return the text --- st2client/st2client/models/core.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/st2client/st2client/models/core.py b/st2client/st2client/models/core.py index ab4b0e0aa9..633e57911f 100644 --- a/st2client/st2client/models/core.py +++ b/st2client/st2client/models/core.py @@ -555,7 +555,7 @@ def get_result(self, execution_id, **kwargs): if response.status_code != http_client.OK: self.handle_error(response) - return orjson.loads(response.text) + return response.text @add_auth_token_to_kwargs_from_env def pause(self, execution_id, **kwargs):