diff --git a/royalnet/engineer/command.py b/royalnet/engineer/command.py index f1e5332d..939a0b0f 100644 --- a/royalnet/engineer/command.py +++ b/royalnet/engineer/command.py @@ -96,13 +96,12 @@ class Command: """ A conversation which runs the command. """ - log.debug(f"Getting a message from the queue...") - try: - msg: bullet.Message = (_sentry | wrench.Type(bullet.Message)).get_nowait() - except asyncio.QueueEmpty: - log.debug(f"No message found in the queue, returning...") - return + log.debug(f"Getting a bullet from the queue...") + b: bullet.Bullet = await _sentry + if not isinstance(b, bullet.Message): + log.debug(f"Bullet is not a message, returning...") + msg: bullet.Message = b log.debug(f"Getting text of {msg}...") text = await msg.text()