diff --git a/src/applications/temporal_worker/__main__.py b/src/applications/temporal_worker/__main__.py index 926e3ee..d794219 100644 --- a/src/applications/temporal_worker/__main__.py +++ b/src/applications/temporal_worker/__main__.py @@ -1,6 +1,6 @@ from asyncio import run -from temporalio.client import Client +from temporalio.client import Client, ScheduleAlreadyRunningError from temporalio.worker import Worker from applications.schedule_sync.activities import ScheduleSyncActivity @@ -14,9 +14,10 @@ async def main(): client: Client = await Client.connect("temporal:7233", namespace="default") for id, schedule in ScheduleSyncWorkflow.get_schedules().items(): - await client.create_schedule( - f"ScheduleSyncWorkflow-{id}", schedule - ) + try: + await client.create_schedule(f"ScheduleSyncWorkflow-{id}", schedule) + except ScheduleAlreadyRunningError: + pass worker: Worker = Worker( client,