This commit is contained in:
2025-04-22 00:18:14 +02:00
parent 2ef3148d46
commit 28c64341e1

View File

@@ -26,4 +26,7 @@ class StreamsCheckWorkflow:
@workflow.run @workflow.run
async def run(self): async def run(self):
await check_streams_states() await workflow.start_activity(
check_streams_states,
schedule_to_close_timeout=timedelta(minutes=1)
)