From 0ec557200b1221f2a3a6ba4d24ccb3627fee4048 Mon Sep 17 00:00:00 2001 From: Maaike Date: Fri, 6 Sep 2024 08:46:42 +0200 Subject: [PATCH] do not process archived data --- wis2box-management/wis2box/pubsub/subscribe.py | 1 + 1 file changed, 1 insertion(+) diff --git a/wis2box-management/wis2box/pubsub/subscribe.py b/wis2box-management/wis2box/pubsub/subscribe.py index a4e09557..b38c6e1c 100644 --- a/wis2box-management/wis2box/pubsub/subscribe.py +++ b/wis2box-management/wis2box/pubsub/subscribe.py @@ -154,6 +154,7 @@ def on_message_handler(self, client, userdata, msg): filepath = f'{STORAGE_SOURCE}/{key}' if key.startswith(STORAGE_ARCHIVE): LOGGER.info(f'Do not process archived-data: {key}') + return # start a new process to handle the received data while len(mp.active_children()) == mp.cpu_count(): sleep(0.05)