fix: pika version 1.3.2

- When tested with most recent pika's version 1.3.2, spec didn't exists. Found pika.DeliveryMode.Persistent instead.
2023-12-07 05:44:30 -03:00 · 2023-12-07 05:44:30 -03:00 · 8497c5f6e5
commit 8497c5f6e5
parent 81bb7d347c
1 changed files with 1 additions and 1 deletions
--- a/python/new_task.py
+++ b/python/new_task.py
@ -15,7 +15,7 @@ channel.basic_publish(
    routing_key='task_queue',
    body=message,
    properties=pika.BasicProperties(
-        delivery_mode=pika.spec.PERSISTENT_DELIVERY_MODE,
+        delivery_mode=pika.DeliveryMode.Persistent,
    ))
 print(f" [x] Sent {message}")
 connection.close()