adding to the schedule example

joshmsmith · joshmsmith · commit 3ee5ef72265c · 2024-08-01T09:48:46.000-04:00
diff --git a/schedules/list_schedule.py b/schedules/list_schedule.py
@@ -6,6 +6,7 @@
 async def main() -> None:
     client = await Client.connect("localhost:7233")
 
+    client.list_schedules()
     async for schedule in await client.list_schedules():
         print(f"List Schedule Info: {schedule.info}.")
 
diff --git a/schedules/start_schedule_daily.py b/schedules/start_schedule_daily.py
@@ -0,0 +1,35 @@
+import asyncio
+from datetime import timedelta
+
+from temporalio.client import (
+    Client,
+    Schedule,
+    ScheduleActionStartWorkflow,
+    ScheduleIntervalSpec,
+    ScheduleSpec,
+    ScheduleState,
+)
+from your_workflows import YourSchedulesWorkflow
+
+
+async def main():
+    client = await Client.connect("localhost:7233")
+    await client.create_schedule(
+        "workflow-schedule-id-daily",
+        Schedule(
+            action=ScheduleActionStartWorkflow(
+                YourSchedulesWorkflow.run,
+                "my schedule arg",
+                id="schedules-workflow-id",
+                task_queue="schedules-task-queue",
+            ),
+            spec=ScheduleSpec(
+                intervals=[ScheduleIntervalSpec(every=timedelta(days=1))]
+            ),
+            state=ScheduleState(note="Here's a note on my Schedule."),
+        ),
+    )
+
+
+if __name__ == "__main__":
+    asyncio.run(main())
diff --git a/schedules/start_schedule_first_of_month.py b/schedules/start_schedule_first_of_month.py
@@ -0,0 +1,37 @@
+import asyncio
+from datetime import timedelta
+
+from temporalio.client import (
+    Client,
+    Schedule,
+    ScheduleActionStartWorkflow,
+    ScheduleIntervalSpec,
+    ScheduleCalendarSpec,
+    ScheduleRange,
+    ScheduleSpec,
+    ScheduleState,
+)
+from your_workflows import YourSchedulesWorkflow
+
+
+async def main():
+    client = await Client.connect("localhost:7233")
+    await client.create_schedule(
+        "workflow-schedule-id-first-of-month",
+        Schedule(
+            action=ScheduleActionStartWorkflow(
+                YourSchedulesWorkflow.run,
+                "my schedule arg",
+                id="schedules-workflow-id",
+                task_queue="schedules-task-queue",
+            ),
+            spec=ScheduleSpec(
+                calendars=[ScheduleCalendarSpec(day_of_month=(ScheduleRange(1,),))]
+            ),
+            state=ScheduleState(note="Here's a note on my Schedule."),
+        ),
+    )
+
+
+if __name__ == "__main__":
+    asyncio.run(main())
