RabbitMQTopic: set max_publish_concurrency to 0

Flared · Nov 29, 2023 · 3644719 · 3644719
1 parent 5dab2fc
commit 3644719
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/saturn_engine/worker/topics/rabbitmq.py b/src/saturn_engine/worker/topics/rabbitmq.py
@@ -82,7 +82,7 @@ class Options:
         prefetch_count: t.Optional[int] = 1
         serializer: RabbitMQSerializer = RabbitMQSerializer.JSON
         log_above_size: t.Optional[int] = None
-        max_publish_concurrency: int = 8
+        max_publish_concurrency: int = 0
         max_retry: int | None = None
         arguments: dict[str, t.Any] = dataclasses.field(default_factory=dict)
         exchange: Exchange | None = None