diff --git a/src/applications/schedule_sync/activities/sync.py b/src/applications/schedule_sync/activities/sync.py index 2f03bac..2ac28b6 100644 --- a/src/applications/schedule_sync/activities/sync.py +++ b/src/applications/schedule_sync/activities/sync.py @@ -1,7 +1,8 @@ -from temporalio import activity +from temporalio import activity, workflow -from applications.common.repositories.streamers import StreamerConfigRepository -from applications.schedule_sync.synchronizer import syncronize +with workflow.unsafe.imports_passed_through(): + from applications.common.repositories.streamers import StreamerConfigRepository + from applications.schedule_sync.synchronizer import syncronize class ScheduleSyncActivity: diff --git a/src/applications/schedule_sync/workflows/sync.py b/src/applications/schedule_sync/workflows/sync.py index 38d42e4..9538e78 100644 --- a/src/applications/schedule_sync/workflows/sync.py +++ b/src/applications/schedule_sync/workflows/sync.py @@ -3,9 +3,8 @@ from datetime import timedelta from temporalio import workflow from temporalio.client import Schedule, ScheduleActionStartWorkflow, ScheduleSpec, ScheduleIntervalSpec -from applications.common.repositories.streamers import StreamerConfigRepository - with workflow.unsafe.imports_passed_through(): + from applications.common.repositories.streamers import StreamerConfigRepository from applications.schedule_sync.activities import ScheduleSyncActivity