clear_queue

Author: deanm0000

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "dean_utils"
-version="0.0.25"
+version="0.0.26"
 authors=[
     { name="Dean MacGregor", email="[email protected]"}
 ]

src/dean_utils/utils/az_utils.py

@@ -143,6 +143,17 @@ async def delete_message(
         return task
 
 
+async def clear_messages(
+    queue,
+    **kwargs,
+):
+    async with AIO_SERVE.get_queue_client(
+        queue, message_encode_policy=TextBase64EncodePolicy()
+    ) as aio_client:
+        task = await aio_client.clear_messages(**kwargs)
+        return task
+
+
 class async_abfs:
     def __init__(self, connection_string=os.environ["Synblob"]):
         self.connection_string = connection_string