We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a6dc2af commit 15525ddCopy full SHA for 15525dd
1 file changed
archipy/adapters/temporal/adapters.py
@@ -412,19 +412,21 @@ async def create_schedule(
412
workflow_class: Any,
413
spec: ScheduleSpec,
414
task_queue: str,
415
- workflow_id_prefix: str | None = None,
+ workflow_id: str | None = None,
416
+ schedule_policy: SchedulePolicy | None = None,
417
) -> None:
418
"""Create a schedule for a workflow."""
419
client = await self.get_client()
420
421
sched = Schedule(
422
action=ScheduleActionStartWorkflow(
423
workflow_class,
- id=workflow_id_prefix,
424
+ id=workflow_id,
425
task_queue=task_queue,
426
),
427
spec=spec,
- policy=SchedulePolicy(
428
+ policy=schedule_policy
429
+ or SchedulePolicy(
430
overlap=ScheduleOverlapPolicy.SKIP,
431
432
)
0 commit comments