StreamLostError: Stream connection lost: ConnectionResetError(104, 'Connection reset by peer')

[ntindle]

Sentry Issue: AUTOGPT-SERVER-3F6

StreamLostError: Stream connection lost: ConnectionResetError(104, 'Connection reset by peer')
  File "starlette/applications.py", line 112, in __call__
    await self.middleware_stack(scope, receive, send)
  File "starlette/middleware/errors.py", line 187, in __call__
    raise exc
  File "starlette/middleware/errors.py", line 165, in __call__
    await self.app(scope, receive, _send)
  File "starlette/middleware/exceptions.py", line 62, in __call__
    await wrap_app_handling_exceptions(self.app, conn)(scope, receive, send)
  File "starlette/_exception_handler.py", line 53, in wrapped_app
    raise exc
  File "starlette/_exception_handler.py", line 42, in wrapped_app
    await app(scope, receive, sender)
  File "starlette/routing.py", line 715, in __call__
    await self.middleware_stack(scope, receive, send)
  File "starlette/routing.py", line 735, in app
    await route.handle(scope, receive, send)
  File "starlette/routing.py", line 288, in handle
    await self.app(scope, receive, send)
  File "starlette/routing.py", line 76, in app
    await wrap_app_handling_exceptions(app, request)(scope, receive, send)
  File "starlette/_exception_handler.py", line 53, in wrapped_app
    raise exc
  File "starlette/_exception_handler.py", line 42, in wrapped_app
    await app(scope, receive, sender)
  File "starlette/routing.py", line 73, in app
    response = await f(request)
  File "fastapi/routing.py", line 301, in app
    raw_response = await run_endpoint_function(
  File "fastapi/routing.py", line 212, in run_endpoint_function
    return await dependant.call(**values)
  File "backend/server/routers/v1.py", line 619, in execute_graph
    execution_utils.get_execution_queue().publish_message(
  File "backend/data/rabbitmq.py", line 178, in publish_message
    self._channel.basic_publish(
  File "pika/adapters/blocking_connection.py", line 2265, in basic_publish
    self._flush_output()
  File "pika/adapters/blocking_connection.py", line 1353, in _flush_output
    self._connection._flush_output(lambda: self.is_closed, *waiters)
  File "pika/adapters/blocking_connection.py", line 523, in _flush_output
    raise self._closed_result.value.error