Merge pull request #43 from oceanprotocol/fix-non-serializable-responses

Sanitize responses to provider when needed

operator_service/routes.py

@@ -23,7 +23,7 @@
 from operator_service.utils import (
     create_compute_job,
     check_required_attributes,
-    decimals_to_float,
+    sanitize_response_for_provider,
     generate_new_id,
     process_signature_validation,
     get_compute_resources,
@@ -209,7 +209,9 @@ def start_compute_job():
     status_list = get_sql_status(agreement_id, str(job_id), owner)
 
     return Response(
-        json.dumps(decimals_to_float(status_list)), 200, headers=standard_headers
+        json.dumps(sanitize_response_for_provider(status_list)),
+        200,
+        headers=standard_headers,
     )
 
 
@@ -399,7 +401,9 @@ def get_compute_job_status():
         api_response = get_sql_status(agreement_id, job_id, owner)
 
         return Response(
-            json.dumps(decimals_to_float(api_response)), 200, headers=standard_headers
+            json.dumps(sanitize_response_for_provider(api_response)),
+            200,
+            headers=standard_headers,
         )
 
     except ApiException as e:

operator_service/utils.py

@@ -183,17 +183,22 @@ def _generate(_response):
         raise
 
 
-def decimals_to_float(d):
+def sanitize_response_for_provider(d):
     """
-    Recursively convert Decimal to float
+    Sanitize objects to send them to provider by recursively convert Decimal and float values to string
     in: dict | list | tuple | set | str | int | float | None
     out: dict | list | tuple | set | str | int | float | None
     """
     if isinstance(d, Decimal):
-        return float(d)
+        return str(d)
+    elif isinstance(d, float):
+        return str(d)
     elif isinstance(d, dict):
-        return {decimals_to_float(k): decimals_to_float(v) for k, v in d.items()}
+        return {
+            sanitize_response_for_provider(k): sanitize_response_for_provider(v)
+            for k, v in d.items()
+        }
     elif isinstance(d, list):
-        return [decimals_to_float(element) for element in d]
+        return [sanitize_response_for_provider(element) for element in d]
     else:
         return d