From 5c10fb5e2a8d0cb6cac66943cd479334a71d18df Mon Sep 17 00:00:00 2001
From: Metin Dumandag <29387993+mdumandag@users.noreply.github.com>
Date: Wed, 31 Jul 2024 13:14:41 +0300
Subject: [PATCH] Remove delay and not before from enqueue

It is not supported by the server, and the users get an immediate
error from the server when they pass it.

It is kind of a breaking change, but since all they get was an error,
I think it is fine to do it.
---
 qstash/asyncio/message.py | 24 ++----------------------
 qstash/message.py         | 24 ++----------------------
 2 files changed, 4 insertions(+), 44 deletions(-)

diff --git a/qstash/asyncio/message.py b/qstash/asyncio/message.py
index 5750f01..4ac383e 100644
--- a/qstash/asyncio/message.py
+++ b/qstash/asyncio/message.py
@@ -204,8 +204,6 @@ async def enqueue(
         retries: Optional[int] = None,
         callback: Optional[str] = None,
         failure_callback: Optional[str] = None,
-        delay: Optional[Union[str, int]] = None,
-        not_before: Optional[int] = None,
         deduplication_id: Optional[str] = None,
         content_based_deduplication: Optional[bool] = None,
         timeout: Optional[Union[str, int]] = None,
@@ -234,13 +232,6 @@ async def enqueue(
         :param callback: A callback url that will be called after each attempt.
         :param failure_callback: A failure callback url that will be called when a delivery
             is failed, that is when all the defined retries are exhausted.
-        :param delay: Delay the message delivery. The format for the delay string is a
-            number followed by duration abbreviation, like `10s`. Available durations
-            are `s` (seconds), `m` (minutes), `h` (hours), and `d` (days). As convenience,
-            it is also possible to specify the delay as an integer, which will be
-            interpreted as delay in seconds.
-        :param not_before: Delay the message until a certain time in the future.
-            The format is a unix timestamp in seconds, based on the UTC timezone.
         :param deduplication_id: Id to use while deduplicating messages.
         :param content_based_deduplication: Automatically deduplicate messages based on
             their content.
@@ -264,8 +255,8 @@ async def enqueue(
             retries=retries,
             callback=callback,
             failure_callback=failure_callback,
-            delay=delay,
-            not_before=not_before,
+            delay=None,
+            not_before=None,
             deduplication_id=deduplication_id,
             content_based_deduplication=content_based_deduplication,
             timeout=timeout,
@@ -293,8 +284,6 @@ async def enqueue_json(
         retries: Optional[int] = None,
         callback: Optional[str] = None,
         failure_callback: Optional[str] = None,
-        delay: Optional[Union[str, int]] = None,
-        not_before: Optional[int] = None,
         deduplication_id: Optional[str] = None,
         content_based_deduplication: Optional[bool] = None,
         timeout: Optional[Union[str, int]] = None,
@@ -324,13 +313,6 @@ async def enqueue_json(
         :param callback: A callback url that will be called after each attempt.
         :param failure_callback: A failure callback url that will be called when a delivery
             is failed, that is when all the defined retries are exhausted.
-        :param delay: Delay the message delivery. The format for the delay string is a
-            number followed by duration abbreviation, like `10s`. Available durations
-            are `s` (seconds), `m` (minutes), `h` (hours), and `d` (days). As convenience,
-            it is also possible to specify the delay as an integer, which will be
-            interpreted as delay in seconds.
-        :param not_before: Delay the message until a certain time in the future.
-            The format is a unix timestamp in seconds, based on the UTC timezone.
         :param deduplication_id: Id to use while deduplicating messages.
         :param content_based_deduplication: Automatically deduplicate messages based on
             their content.
@@ -351,8 +333,6 @@ async def enqueue_json(
             retries=retries,
             callback=callback,
             failure_callback=failure_callback,
-            delay=delay,
-            not_before=not_before,
             deduplication_id=deduplication_id,
             content_based_deduplication=content_based_deduplication,
             timeout=timeout,
diff --git a/qstash/message.py b/qstash/message.py
index 244827d..2f089e9 100644
--- a/qstash/message.py
+++ b/qstash/message.py
@@ -787,8 +787,6 @@ def enqueue(
         retries: Optional[int] = None,
         callback: Optional[str] = None,
         failure_callback: Optional[str] = None,
-        delay: Optional[Union[str, int]] = None,
-        not_before: Optional[int] = None,
         deduplication_id: Optional[str] = None,
         content_based_deduplication: Optional[bool] = None,
         timeout: Optional[Union[str, int]] = None,
@@ -817,13 +815,6 @@ def enqueue(
         :param callback: A callback url that will be called after each attempt.
         :param failure_callback: A failure callback url that will be called when a delivery
             is failed, that is when all the defined retries are exhausted.
-        :param delay: Delay the message delivery. The format for the delay string is a
-            number followed by duration abbreviation, like `10s`. Available durations
-            are `s` (seconds), `m` (minutes), `h` (hours), and `d` (days). As convenience,
-            it is also possible to specify the delay as an integer, which will be
-            interpreted as delay in seconds.
-        :param not_before: Delay the message until a certain time in the future.
-            The format is a unix timestamp in seconds, based on the UTC timezone.
         :param deduplication_id: Id to use while deduplicating messages.
         :param content_based_deduplication: Automatically deduplicate messages based on
             their content.
@@ -847,8 +838,8 @@ def enqueue(
             retries=retries,
             callback=callback,
             failure_callback=failure_callback,
-            delay=delay,
-            not_before=not_before,
+            delay=None,
+            not_before=None,
             deduplication_id=deduplication_id,
             content_based_deduplication=content_based_deduplication,
             timeout=timeout,
@@ -876,8 +867,6 @@ def enqueue_json(
         retries: Optional[int] = None,
         callback: Optional[str] = None,
         failure_callback: Optional[str] = None,
-        delay: Optional[Union[str, int]] = None,
-        not_before: Optional[int] = None,
         deduplication_id: Optional[str] = None,
         content_based_deduplication: Optional[bool] = None,
         timeout: Optional[Union[str, int]] = None,
@@ -907,13 +896,6 @@ def enqueue_json(
         :param callback: A callback url that will be called after each attempt.
         :param failure_callback: A failure callback url that will be called when a delivery
             is failed, that is when all the defined retries are exhausted.
-        :param delay: Delay the message delivery. The format for the delay string is a
-            number followed by duration abbreviation, like `10s`. Available durations
-            are `s` (seconds), `m` (minutes), `h` (hours), and `d` (days). As convenience,
-            it is also possible to specify the delay as an integer, which will be
-            interpreted as delay in seconds.
-        :param not_before: Delay the message until a certain time in the future.
-            The format is a unix timestamp in seconds, based on the UTC timezone.
         :param deduplication_id: Id to use while deduplicating messages.
         :param content_based_deduplication: Automatically deduplicate messages based on
             their content.
@@ -934,8 +916,6 @@ def enqueue_json(
             retries=retries,
             callback=callback,
             failure_callback=failure_callback,
-            delay=delay,
-            not_before=not_before,
             deduplication_id=deduplication_id,
             content_based_deduplication=content_based_deduplication,
             timeout=timeout,