From cb464ad9f368271af8cc7b1dd7951a92e737af31 Mon Sep 17 00:00:00 2001
From: Bulat Kurbanov <kurbanovbul@gmail.com>
Date: Mon, 21 Apr 2025 23:52:10 +0200
Subject: [PATCH] Fix

---
 src/applications/schedule_sync/workflows/sync.py                | 2 +-
 .../twitch_webhook/workflows/on_reward_redemption.py            | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

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