This commit is contained in:
2025-04-21 20:54:55 +02:00
parent dc2486f5ff
commit acaff281c3
2 changed files with 5 additions and 5 deletions

View File

@@ -1,7 +1,8 @@
from temporalio import activity from temporalio import activity, workflow
from applications.common.repositories.streamers import StreamerConfigRepository with workflow.unsafe.imports_passed_through():
from applications.schedule_sync.synchronizer import syncronize from applications.common.repositories.streamers import StreamerConfigRepository
from applications.schedule_sync.synchronizer import syncronize
class ScheduleSyncActivity: class ScheduleSyncActivity:

View File

@@ -3,9 +3,8 @@ from datetime import timedelta
from temporalio import workflow from temporalio import workflow
from temporalio.client import Schedule, ScheduleActionStartWorkflow, ScheduleSpec, ScheduleIntervalSpec from temporalio.client import Schedule, ScheduleActionStartWorkflow, ScheduleSpec, ScheduleIntervalSpec
from applications.common.repositories.streamers import StreamerConfigRepository
with workflow.unsafe.imports_passed_through(): with workflow.unsafe.imports_passed_through():
from applications.common.repositories.streamers import StreamerConfigRepository
from applications.schedule_sync.activities import ScheduleSyncActivity from applications.schedule_sync.activities import ScheduleSyncActivity