From 273fb488d896044b6d954e1d779f5cbd836db35a Mon Sep 17 00:00:00 2001 From: Joost Ellerbroek Date: Fri, 30 Aug 2024 16:22:58 +0200 Subject: [PATCH] Fixed missing function import --- bluesky/network/publisher.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/bluesky/network/publisher.py b/bluesky/network/publisher.py index 1b81bbecf..f1c8281be 100644 --- a/bluesky/network/publisher.py +++ b/bluesky/network/publisher.py @@ -8,6 +8,7 @@ from bluesky.core.walltime import Timer from bluesky.network.common import ActionType from bluesky.network.subscriber import subscriber +from bluesky.network.sharedstate import _recursive_update import bluesky.network.context as ctx @@ -57,7 +58,7 @@ def collect(cls, topic: str, payload: list, to_group: str=''): payload[1] = {k:[v] for k, v in payload[1].items()} store.extend(payload) elif payload[0] == ActionType.Update.value: - recursive_update(store[1], payload[1]) + _recursive_update(store[1], payload[1]) elif payload[0] == ActionType.Append.value: for key, item in payload[1].items(): store[1][key].append(item)