fix: lint

Author: root

examples/python/scheduled/programatic-async.py

@@ -16,6 +16,7 @@ async def create_scheduled() -> None:
         additional_metadata={
             "customer_id": "customer-a",
         },
+        priority=3,
     )
 
     scheduled_run.metadata.id  # the id of the scheduled run trigger

examples/python/scheduled/programatic-sync.py

@@ -15,6 +15,7 @@
     additional_metadata={
         "customer_id": "customer-a",
     },
+    priority=2,
 )
 
 id = scheduled_run.metadata.id  # the id of the scheduled run trigger

sdks/go/features/schedules.go

@@ -38,8 +38,8 @@ type SchedulesClient struct {
 }
 
 type BulkUpdateScheduledRunItem struct {
-	TriggerAt      time.Time `json:"triggerAt"`
 	ScheduledRunId string    `json:"scheduledRunId"`
+	TriggerAt      time.Time `json:"triggerAt"`
 }
 
 // NewSchedulesClient creates a new SchedulesClient

sdks/python/examples/scheduled/programatic-async.py

@@ -16,7 +16,7 @@ async def create_scheduled() -> None:
         additional_metadata={
             "customer_id": "customer-a",
         },
-        priority=3
+        priority=3,
     )
 
     scheduled_run.metadata.id  # the id of the scheduled run trigger

sdks/python/examples/scheduled/programatic-sync.py

@@ -15,7 +15,7 @@
     additional_metadata={
         "customer_id": "customer-a",
     },
-    priority=2
+    priority=2,
 )
 
 id = scheduled_run.metadata.id  # the id of the scheduled run trigger

sdks/python/hatchet_sdk/features/scheduled.py

@@ -75,6 +75,7 @@ def create(
         :param trigger_at: The datetime when the run should be triggered.
         :param input: The input data for the scheduled workflow.
         :param additional_metadata: Additional metadata associated with the future run as a key-value pair.
+        :param priority: The priority of the scheduled workflow run. Must be between 1 and 3, inclusive.
 
         :return: The created scheduled workflow instance.
         """
@@ -86,7 +87,7 @@ def create(
                     triggerAt=trigger_at,
                     input=input,
                     additionalMetadata=additional_metadata,
-                    priority=priority
+                    priority=priority,
                 ),
             )
 
@@ -96,6 +97,7 @@ async def aio_create(
         trigger_at: datetime.datetime,
         input: JSONSerializableMapping,
         additional_metadata: JSONSerializableMapping,
+        priority: int | None = None,
     ) -> ScheduledWorkflows:
         """
         Creates a new scheduled workflow run.
@@ -106,16 +108,13 @@ async def aio_create(
         :param trigger_at: The datetime when the run should be triggered.
         :param input: The input data for the scheduled workflow.
         :param additional_metadata: Additional metadata associated with the future run as a key-value pair.
+        :param priority: The priority of the scheduled workflow run. Must be between 1 and 3, inclusive.
 
         :return: The created scheduled workflow instance.
         """
 
         return await asyncio.to_thread(
-            self.create,
-            workflow_name,
-            trigger_at,
-            input,
-            additional_metadata,
+            self.create, workflow_name, trigger_at, input, additional_metadata, priority
         )
 
     def delete(self, scheduled_id: str) -> None: