Avoid `numpy` type usage on the wire

ems_to_bidir_streaming
Tyler Goodlet 2021-06-01 10:38:11 -04:00
parent edf3af9777
commit f4c9e20f0d
1 changed files with 2 additions and 2 deletions

View File

@ -217,8 +217,8 @@ async def allocate_persistent_feed(
times = shm.array['time']
delay_s = times[-1] - times[times != times[-1]][-1]
# pass OHLC sample rate in seconds
init_msg[symbol]['sample_rate'] = delay_s
# pass OHLC sample rate in seconds (be sure to use python int type)
init_msg[symbol]['sample_rate'] = int(delay_s)
# yield back control to starting nursery
task_status.started((init_msg, first_quote))