Enable backpressure during data-feed layer startup to avoid overruns

paper_trade_improvements_rebase
algorandpa 2023-02-14 19:46:09 -05:00 committed by jaredgoldman
parent f79f0ede5b
commit 0527310071
2 changed files with 2 additions and 2 deletions

View File

@ -1467,7 +1467,7 @@ async def maybe_open_feed(
'tick_throttle': kwargs.get('tick_throttle'),
# XXX: super critical to have bool defaults here XD
'backpressure': kwargs.get('backpressure', True),
# 'backpressure': kwargs.get('backpressure', True),
'start_stream': kwargs.get('start_stream', True),
},
key=fqsn,

View File

@ -176,5 +176,5 @@ def test_ensure_ems_in_paper_actors(
) as exc_info:
trio.run(main)
cancel_msg: str = '_emsd_main was remotely cancelled by its caller'
cancel_msg: str = '_emsd_main()` was remotely cancelled by its caller'
assert cancel_msg in exc_info.value.args[0]