Wamp serialization error fix: huge unsigned int (#4236)

* Wamp serialization error fix: huge unsigned int

* deep bigint to string conversion definition for collections

* lint

* all integers converted to string

golem/rpc/utils.py

@@ -40,3 +40,17 @@ def predicate(member):
             continue
         mapping[uri] = method
     return mapping
+
+
+def int_to_string(item):
+    # Deeply convert all integer elements of collections to string
+    if isinstance(item, list):
+        for k, v in enumerate(item):
+            item[k] = int_to_string(v)
+    elif isinstance(item, dict):
+        for k, v in item.items():
+            item[k] = int_to_string(v)
+    elif isinstance(item, int):
+        item = str(item)
+
+    return item

golem/task/rpc.py

@@ -71,7 +71,7 @@ def _validate_task_dict(client, task_dict) -> None:
             subtasks_count=subtasks_count,
             optimize_total=False,
             use_frames=options.get('frame_count', 1) > 1,
-            frames=[None]*options.get('frame_count', 1),
+            frames=[None] * options.get('frame_count', 1),
         )
         if computed_subtasks != subtasks_count:
             raise ValueError(
@@ -347,7 +347,7 @@ def _start_task(client, task, resource_server_result):
 
 @defer.inlineCallbacks
 def enqueue_new_task(client, task, force=False) \
-            -> typing.Generator[defer.Deferred, typing.Any, taskbase.Task]:
+        -> typing.Generator[defer.Deferred, typing.Any, taskbase.Task]:
     """Feed a fresh Task to all golem subsystems"""
     validate_client(client)
     task_id = task.header.task_id
@@ -401,7 +401,8 @@ def _create_task_error(e, _self, task_dict, **_kwargs) \
     logger.error("Cannot create task %r: %s", task_dict, e)
 
     if hasattr(e, 'to_dict'):
-        return None, e.to_dict()
+        temp_dict = rpc_utils.int_to_string(e.to_dict())
+        return None, temp_dict
 
     return None, str(e)
 
@@ -729,10 +730,9 @@ def get_estimated_cost(
 
     @rpc_utils.expose('comp.task.rendering.task_fragments')
     def get_fragments(self, task_id: str) -> \
-            typing.Tuple[
-                    typing.Optional[typing.Dict[int, typing.List[typing.Dict]]],
-                    typing.Optional[str]
-            ]:
+        typing.Tuple[
+                typing.Optional[typing.Dict[int, typing.List[typing.Dict]]],
+                typing.Optional[str]]:
         """
         Returns the task fragments for a given rendering task. A single task
         fragment is a collection of subtasks referring to the same, common part