code: async def query(self, *args):
          
  
          self._check_receive_loop()
          try:
              await self.connection.send(args)
              return await self.receive_bilateral_response()
          except CommandError as ex:
              ex.setCommand(args)
              raise ex
docs: Send a query to the Watchman service and return the response.