From 00d6258a2420e66b66e86d36421462e6c2716bdc Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Fri, 5 Nov 2021 15:45:56 -0400 Subject: [PATCH] Stopgap: don't rerun Context.started() fsp calc task --- piker/fsp/_engine.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/piker/fsp/_engine.py b/piker/fsp/_engine.py index 00cccdbd..2b7056da 100644 --- a/piker/fsp/_engine.py +++ b/piker/fsp/_engine.py @@ -144,10 +144,13 @@ async def fsp_compute( profiler(f'{func_name} pushed history') profiler.finish() + # TODO: UGH, what is the right way to do something like this? + if not ctx._started_called: + await ctx.started(index) + # setup a respawn handle with trio.CancelScope() as cs: tracker = TaskTracker(trio.Event(), cs) - await ctx.started(index) task_status.started((tracker, index)) profiler(f'{func_name} yield last index')