diff --git a/src/applications/schedule_sync/activities/sync.py b/src/applications/schedule_sync/activities/sync.py index 2ac28b6..2f03bac 100644 --- a/src/applications/schedule_sync/activities/sync.py +++ b/src/applications/schedule_sync/activities/sync.py @@ -1,8 +1,7 @@ -from temporalio import activity, workflow +from temporalio import activity -with workflow.unsafe.imports_passed_through(): - from applications.common.repositories.streamers import StreamerConfigRepository - from applications.schedule_sync.synchronizer import syncronize +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 9538e78..8516729 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 -with workflow.unsafe.imports_passed_through(): - from applications.common.repositories.streamers import StreamerConfigRepository - from applications.schedule_sync.activities import ScheduleSyncActivity +from applications.common.repositories.streamers import StreamerConfigRepository +from applications.schedule_sync.activities import ScheduleSyncActivity TASK_QUEUE = "main" diff --git a/src/applications/temporal_worker/__main__.py b/src/applications/temporal_worker/__main__.py index d794219..534c1dd 100644 --- a/src/applications/temporal_worker/__main__.py +++ b/src/applications/temporal_worker/__main__.py @@ -1,7 +1,7 @@ from asyncio import run from temporalio.client import Client, ScheduleAlreadyRunningError -from temporalio.worker import Worker +from temporalio.worker import Worker, UnsandboxedWorkflowRunner from applications.schedule_sync.activities import ScheduleSyncActivity from applications.schedule_sync.workflows import ScheduleSyncWorkflow @@ -28,6 +28,7 @@ async def main(): activities=[ ScheduleSyncActivity.syncronize ], + workflow_runner=UnsandboxedWorkflowRunner(), ) await worker.run()