diff --git a/src/applications/schedule_sync/workflows/sync.py b/src/applications/schedule_sync/workflows/sync.py index e3d1ee3..f6eaf7d 100644 --- a/src/applications/schedule_sync/workflows/sync.py +++ b/src/applications/schedule_sync/workflows/sync.py @@ -33,7 +33,7 @@ class ScheduleSyncWorkflow: if streamer.integrations.discord is None: continue - await workflow.execute_activity( + await workflow.start_activity( syncronize, streamer.twitch.id ) diff --git a/src/applications/twitch_webhook/workflows/on_reward_redemption.py b/src/applications/twitch_webhook/workflows/on_reward_redemption.py index f06803b..3255897 100644 --- a/src/applications/twitch_webhook/workflows/on_reward_redemption.py +++ b/src/applications/twitch_webhook/workflows/on_reward_redemption.py @@ -9,7 +9,7 @@ from applications.temporal_worker.queues import MAIN_QUEUE class OnRewardRedemptionWorkflow: @workflow.run async def run(self, reward: RewardRedemption): - await workflow.execute_activity( + await workflow.start_activity( on_redemption_reward_add_activity, reward, task_queue=MAIN_QUEUE