Merge pull request #96 from nrccua/DS-356-remove-results-from-callbac…

…k-when-error-in-longrun Remove results from callback when error in LongRunningJobs
nrccua · Feb 3, 2023 · 8d28a39 · 8d28a39
2 parents 52267ad + 9b3f964
commit 8d28a39
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 1 deletion.
diff --git a/HISTORY.rst b/HISTORY.rst
@@ -3,6 +3,11 @@ History
 =======
 
 
+v0.17.31 (2023-02-03)
+
+* Remove results from callback when error in LongRunningJobs.
+
+
 v0.17.30 (2023-02-03)
 
 * Update LongRunningJobs to gracefully deal with exceptions during narwhal execution.

diff --git a/aioradio/long_running_jobs.py b/aioradio/long_running_jobs.py
@@ -207,6 +207,7 @@ async def __sqs_pull_messages_and_run_jobs__(self):
                 json = {'results': data, 'uuid': body['uuid']}
                 if error:
                     json['error'] = error
+                    del json['results']
                 create_task(self.httpx_client.post(callback_url, json=json, timeout=30))
 
             # Update the hashed UUID with processing results

diff --git a/setup.py b/setup.py
@@ -7,7 +7,7 @@
     long_description = fileobj.read()
 
 setup(name='aioradio',
-    version='0.17.30',
+    version='0.17.31',
     description='Generic asynchronous i/o python utilities for AWS services (SQS, S3, DynamoDB, Secrets Manager), Redis, MSSQL (pyodbc), JIRA and more',
     long_description=long_description,
     long_description_content_type="text/markdown",