From 0527310071bbbb9cc2b23c6fda03a81b84effd93 Mon Sep 17 00:00:00 2001 From: algorandpa Date: Tue, 14 Feb 2023 19:46:09 -0500 Subject: [PATCH] Enable backpressure during data-feed layer startup to avoid overruns --- piker/data/feed.py | 2 +- tests/test_services.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/piker/data/feed.py b/piker/data/feed.py index 906f4bb4..b045ad41 100644 --- a/piker/data/feed.py +++ b/piker/data/feed.py @@ -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, diff --git a/tests/test_services.py b/tests/test_services.py index 6b67d3c5..11f0db7c 100644 --- a/tests/test_services.py +++ b/tests/test_services.py @@ -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]