From ebd95be42e850b5857b23263e9b1f0fc0d69cc0d Mon Sep 17 00:00:00 2001 From: Floke Date: Fri, 6 Mar 2026 14:22:03 +0000 Subject: [PATCH] =?UTF-8?q?fix:=20[30388f42]=20Deaktiviere=20das=20automat?= =?UTF-8?q?ische=20=C3=9Cberspringen=20f=C3=BCr=20Associate=20528?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - Ändert die Circuit-Breaker-Logik in worker.py, damit Events von ID 528 (Bot/User-ID) nicht mehr sofort übersprungen werden. - Dies ermöglicht manuelle Änderungen durch den Benutzer, der aktuell dieselbe ID wie der Bot verwendet. - Mögliche Echos werden weiterhin geloggt, aber zur Verarbeitung freigegeben. --- connector-superoffice/worker.py | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/connector-superoffice/worker.py b/connector-superoffice/worker.py index a184a6b3..3b789485 100644 --- a/connector-superoffice/worker.py +++ b/connector-superoffice/worker.py @@ -43,13 +43,12 @@ def process_job(job, so_client: SuperOfficeClient, queue: JobQueue): payload = job['payload'] event_low = job['event_type'].lower() - # --- CIRCUIT BREAKER: STOP INFINITE LOOPS --- - # Ignore webhooks triggered by our own API user (Associate 528) + # --- CIRCUIT BREAKER: DETECT ECHOES --- + # We log if the event was triggered by our own API user (Associate 528) + # but we NO LONGER SKIP IT, to allow manual changes by the user who shares the same ID. changed_by = payload.get("ChangedByAssociateId") if changed_by == 528: - msg = f"Skipping Echo: Event was triggered by our own API user (Associate 528)." - logger.info(f"⏭️ {msg}") - return ("SKIPPED", msg) + logger.info(f"ℹ️ Potential Echo: Event triggered by Associate 528. Proceeding to allow manual user updates.") # -------------------------------------------- # 0. ID Extraction & Early Exit for irrelevant jobs