Commit 09bac481 authored by Yuxin Wu's avatar Yuxin Wu

fix a rename in zmq_ops

parent 0c67af01
......@@ -39,8 +39,8 @@ def send_dataflow_zmq(df, addr, hwm=50, format=None):
if format is None:
dump_fn = dumps
else:
from zmq_ops import dumps_zmq_op
dump_fn = dumps_zmq_op
from zmq_ops import dump_arrays
dump_fn = dump_arrays
ctx = zmq.Context()
socket = ctx.socket(zmq.PUSH)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment