This commit is contained in:
2025-04-21 23:52:10 +02:00
parent bb67ff7bba
commit cb464ad9f3
2 changed files with 2 additions and 2 deletions

View File

@@ -33,7 +33,7 @@ class ScheduleSyncWorkflow:
if streamer.integrations.discord is None: if streamer.integrations.discord is None:
continue continue
await workflow.execute_activity( await workflow.start_activity(
syncronize, syncronize,
streamer.twitch.id streamer.twitch.id
) )

View File

@@ -9,7 +9,7 @@ from applications.temporal_worker.queues import MAIN_QUEUE
class OnRewardRedemptionWorkflow: class OnRewardRedemptionWorkflow:
@workflow.run @workflow.run
async def run(self, reward: RewardRedemption): async def run(self, reward: RewardRedemption):
await workflow.execute_activity( await workflow.start_activity(
on_redemption_reward_add_activity, on_redemption_reward_add_activity,
reward, reward,
task_queue=MAIN_QUEUE task_queue=MAIN_QUEUE