From 886e2b28f97fe599e2e0e51a33d5a72c72fc7cbe Mon Sep 17 00:00:00 2001 From: Sven Augustin Date: Thu, 12 Dec 2024 14:37:31 +0100 Subject: [PATCH] added filter on instrument --- slic/core/acquisition/broker/requeststatus.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/slic/core/acquisition/broker/requeststatus.py b/slic/core/acquisition/broker/requeststatus.py index 2525568c..04e31794 100644 --- a/slic/core/acquisition/broker/requeststatus.py +++ b/slic/core/acquisition/broker/requeststatus.py @@ -20,7 +20,8 @@ class RequestStatus: ) - def __init__(self, broker_url=DEFAULT_BROKER_URL): + def __init__(self, instrument=None, broker_url=DEFAULT_BROKER_URL): + self.instrument = instrument self.broker_url = broker_url for i in self.ENTRIES: @@ -60,6 +61,10 @@ class RequestStatus: body = body.decode() request = json.loads(body) + instrument = request.get("metadata", {}).get("general/instrument") + if instrument is not None and self.instrument is not None and instrument != self.instrument: + return + action = headers["action"] timestamp = datetime.fromtimestamp(timestamp / 1e9)