adjust task limits

Signed-off-by: Andrew Whitehead <[email protected]>

aries_cloudagent/dispatcher.py

@@ -38,7 +38,7 @@ class Dispatcher:
     def __init__(self, context: InjectionContext):
         """Initialize an instance of Dispatcher."""
         self.context = context
-        self.task_queue = TaskQueue(max_active=50)
+        self.task_queue = TaskQueue(max_active=20)
 
     def put_task(self, coro: Coroutine, complete: Callable = None) -> asyncio.Future:
         """Run a task in the task queue, potentially blocking other handlers."""

aries_cloudagent/transport/outbound/manager.py

@@ -77,7 +77,7 @@ def __init__(self, context: InjectionContext):
         self.registered_schemes = {}
         self.registered_transports = {}
         self.running_transports = {}
-        self.task_queue = TaskQueue(max_active=50)
+        self.task_queue = TaskQueue(max_active=100)
         self._process_task: asyncio.Task = None
 
     async def setup(self):
@@ -260,13 +260,11 @@ def enqueue_webhook(
             retries: Override the number of retries
 
         Raises:
-            OutboundDeliveryError: if the associated transport is not registered
+            OutboundDeliveryError: if the associated transport is not running
 
         """
         transport_id = self.get_running_transport_for_endpoint(endpoint)
-        queued = QueuedOutboundMessage(
-            None, None, None, transport_id
-        )
+        queued = QueuedOutboundMessage(None, None, None, transport_id)
         queued.endpoint = f"{endpoint}/topic/{topic}/"
         queued.payload = json.dumps(payload)
         queued.state = QueuedOutboundMessage.STATE_PENDING