diff --git a/nitric/resources/queues.py b/nitric/resources/queues.py index fb0b622..f61bb3e 100644 --- a/nitric/resources/queues.py +++ b/nitric/resources/queues.py @@ -49,7 +49,7 @@ async def complete(self): Only callable for messages that have been dequeued. """ try: - await self._queue.queue_stub.complete( + await self._queue._queue_stub.complete( queue_complete_request=QueueCompleteRequest(queue_name=self._queue.name, lease_id=self.lease_id) ) except GRPCError as grpc_err: