Fix

src/applications/schedule_sync/activities/sync.py

@@ -1,6 +1,5 @@
-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
 

src/applications/schedule_sync/workflows/sync.py

@@ -3,7 +3,6 @@ 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
 

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()