sf-daq/dap
0
1
Fork 2
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

use ExtendedJSONEncoder

Browse Source
This commit is contained in:
augustin_s
2025-11-03 16:39:47 +01:00
parent 941ab51856
commit cce141423d
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
dap/zmqsocks.py
View File

@@ -1,6 +1,8 @@
import numpy as np import numpy as np
import zmq import zmq
from .utils import ExtendedJSONEncoder
FLAGS = 0 FLAGS = 0
@@ -61,10 +63,10 @@ class ZMQSocketsWorker:
def send_accumulator(self, results): def send_accumulator(self, results):
self.accumulator_socket.send_json(results, FLAGS) self.accumulator_socket.send_json(results, FLAGS, cls=ExtendedJSONEncoder)
def send_visualisation(self, results, data): def send_visualisation(self, results, data):
self.visualisation_socket.send_json(results, FLAGS | zmq.SNDMORE) self.visualisation_socket.send_json(results, FLAGS | zmq.SNDMORE, cls=ExtendedJSONEncoder)
self.visualisation_socket.send(data, FLAGS, copy=True, track=True) self.visualisation_socket.send(data, FLAGS, copy=True, track=True)