diff --git a/qstash/asyncio/schedule.py b/qstash/asyncio/schedule.py
index 1b4b90e..609dd5a 100644
--- a/qstash/asyncio/schedule.py
+++ b/qstash/asyncio/schedule.py
@@ -28,6 +28,7 @@ async def create(
         failure_callback: Optional[str] = None,
         delay: Optional[Union[str, int]] = None,
         timeout: Optional[Union[str, int]] = None,
+        schedule_id: Optional[str] = None,
     ) -> str:
         """
         Creates a schedule to send messages periodically.
@@ -54,6 +55,7 @@ async def create(
             When a timeout is specified, it will be used instead of the maximum timeout
             value permitted by the QStash plan. It is useful in scenarios, where a message
             should be delivered with a shorter timeout.
+        :param schedule_id: Schedule id to use. Can be used to update the settings of an existing schedule.
         """
         req_headers = prepare_schedule_headers(
             cron=cron,
@@ -65,6 +67,7 @@ async def create(
             failure_callback=failure_callback,
             delay=delay,
             timeout=timeout,
+            schedule_id=schedule_id,
         )
 
         response = await self._http.request(
@@ -89,6 +92,7 @@ async def create_json(
         failure_callback: Optional[str] = None,
         delay: Optional[Union[str, int]] = None,
         timeout: Optional[Union[str, int]] = None,
+        schedule_id: Optional[str] = None,
     ) -> str:
         """
         Creates a schedule to send messages periodically, automatically serializing the
@@ -116,6 +120,7 @@ async def create_json(
             When a timeout is specified, it will be used instead of the maximum timeout
             value permitted by the QStash plan. It is useful in scenarios, where a message
             should be delivered with a shorter timeout.
+        :param schedule_id: Schedule id to use. Can be used to update the settings of an existing schedule.
         """
         return await self.create(
             destination=destination,
@@ -128,6 +133,8 @@ async def create_json(
             callback=callback,
             failure_callback=failure_callback,
             delay=delay,
+            timeout=timeout,
+            schedule_id=schedule_id,
         )
 
     async def get(self, schedule_id: str) -> Schedule:
diff --git a/qstash/schedule.py b/qstash/schedule.py
index e2324f9..b0c079b 100644
--- a/qstash/schedule.py
+++ b/qstash/schedule.py
@@ -65,6 +65,7 @@ def prepare_schedule_headers(
     failure_callback: Optional[str],
     delay: Optional[Union[str, int]],
     timeout: Optional[Union[str, int]],
+    schedule_id: Optional[str],
 ) -> Dict[str, str]:
     h = {
         "Upstash-Cron": cron,
@@ -104,6 +105,9 @@ def prepare_schedule_headers(
         else:
             h["Upstash-Timeout"] = timeout
 
+    if schedule_id is not None:
+        h["Upstash-Schedule-Id"] = schedule_id
+
     return h
 
 
@@ -144,6 +148,7 @@ def create(
         failure_callback: Optional[str] = None,
         delay: Optional[Union[str, int]] = None,
         timeout: Optional[Union[str, int]] = None,
+        schedule_id: Optional[str] = None,
     ) -> str:
         """
         Creates a schedule to send messages periodically.
@@ -170,6 +175,7 @@ def create(
             When a timeout is specified, it will be used instead of the maximum timeout
             value permitted by the QStash plan. It is useful in scenarios, where a message
             should be delivered with a shorter timeout.
+        :param schedule_id: Schedule id to use. Can be used to update the settings of an existing schedule.
         """
         req_headers = prepare_schedule_headers(
             cron=cron,
@@ -181,6 +187,7 @@ def create(
             failure_callback=failure_callback,
             delay=delay,
             timeout=timeout,
+            schedule_id=schedule_id,
         )
 
         response = self._http.request(
@@ -205,6 +212,7 @@ def create_json(
         failure_callback: Optional[str] = None,
         delay: Optional[Union[str, int]] = None,
         timeout: Optional[Union[str, int]] = None,
+        schedule_id: Optional[str] = None,
     ) -> str:
         """
         Creates a schedule to send messages periodically, automatically serializing the
@@ -232,6 +240,7 @@ def create_json(
             When a timeout is specified, it will be used instead of the maximum timeout
             value permitted by the QStash plan. It is useful in scenarios, where a message
             should be delivered with a shorter timeout.
+        :param schedule_id: Schedule id to use. Can be used to update the settings of an existing schedule.
         """
         return self.create(
             destination=destination,
@@ -245,6 +254,7 @@ def create_json(
             failure_callback=failure_callback,
             delay=delay,
             timeout=timeout,
+            schedule_id=schedule_id,
         )
 
     def get(self, schedule_id: str) -> Schedule: