From 033e4ec6454e45245710982f7778431acfd45c73 Mon Sep 17 00:00:00 2001 From: ValueOn AG Date: Thu, 25 Sep 2025 00:24:26 +0200 Subject: [PATCH] Proper event handling --- modules/features/init.py | 3 --- modules/features/syncDelta/mainSyncDelta.py | 8 ++++---- 2 files changed, 4 insertions(+), 7 deletions(-) diff --git a/modules/features/init.py b/modules/features/init.py index 085671ac..a8d7e73a 100644 --- a/modules/features/init.py +++ b/modules/features/init.py @@ -7,6 +7,3 @@ logger = logging.getLogger(__name__) # Import the syncDelta module to initialize it (this will register the scheduler) from modules.features.syncDelta import mainSyncDelta - -# Run initial sync -asyncio.create_task(mainSyncDelta.scheduled_sync()) diff --git a/modules/features/syncDelta/mainSyncDelta.py b/modules/features/syncDelta/mainSyncDelta.py index 247fc861..2c115671 100644 --- a/modules/features/syncDelta/mainSyncDelta.py +++ b/modules/features/syncDelta/mainSyncDelta.py @@ -838,7 +838,7 @@ try: from modules.shared.eventManagement import eventManager # Register scheduler only in production - if APP_ENV_TYPE == "prod" or APP_ENV_TYPE == "dev": + if APP_ENV_TYPE == "prod": # Schedule sync every 20 minutes (at minutes 00, 20, 40) eventManager.register_cron( job_id="dgsync", @@ -852,9 +852,9 @@ try: logger.info("Registered DG ticket sync via EventManagement (every 20 minutes)") # Run initial sync - import asyncio - asyncio.create_task(scheduled_sync()) - logger.info("Initial sync scheduled") + #import asyncio + #asyncio.create_task(scheduled_sync()) + #logger.info("Initial sync scheduled") else: logger.info(f"Skipping DG scheduler registration for ticket sync in env: {APP_ENV_TYPE}")