fix #153: AsyncResult is not serializable to json

selinon · Jun 1, 2021 · 00cc2e2 · 00cc2e2
1 parent 33dede9
commit 00cc2e2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/selinon/run.py b/selinon/run.py
@@ -23,7 +23,7 @@ def _do_run_flow(kwargs, queue):
     trace_msg = {
         'flow_name': kwargs["flow_name"],
         'node_args': kwargs["node_args"],
-        'dispatcher_id': dispatcher_id,
+        'dispatcher_id': str(dispatcher_id),
         'queue': queue,
         'selective': kwargs.get("selective"),
     }