pikers
/
piker
3
0
Fork 0
Code Issues 4 Pull Requests 6 Packages Projects Releases Wiki Activity

Use throttle period for wait-on-clearing-event timeout

epoch_index_backup
Tyler Goodlet 2022-11-17 18:25:46 -05:00
parent e7daf09a83
commit de1c0b1399
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
piker/data/_sampling.py
View File

@ -525,7 +525,7 @@ async def uniform_rate_send(
# we have a quote already so send it now. # we have a quote already so send it now.
with trio.move_on_after(1/60) as cs: with trio.move_on_after(throttle_period) as cs:
while ( while (
not set(ticks_by_type).intersection(clear_types) not set(ticks_by_type).intersection(clear_types)
): ):