diff --git a/wis2box-management/wis2box/pubsub/subscribe.py b/wis2box-management/wis2box/pubsub/subscribe.py index a4e095575..b38c6e1c6 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)