code: def raw(self, command, arguments, queue=None, max_time=None, stream=False, tags=None, id=None):
          
          if not id:
              id = str(uuid.uuid4())
  
          payload = {
              'id': id,
              'command': command,
              'arguments': arguments,
              'queue': queue,
              'max_time': max_time,
              'stream': stream,
              'tags': tags,
          }
  
          self._raw_chk.check(payload)
          flag = 'result:{}:flag'.format(id)
          self._redis.rpush('core:default', json.dumps(payload))
          if self._redis.brpoplpush(flag, flag, DefaultTimeout) is None:
              TimeoutError('failed to queue job {}'.format(id))
          logger.debug('%s >> g8core.%s(%s)', id, command, ', '.join(("%s=%s" % (k, v) for k, v in arguments.items())))
  
          return Response(self, id)
docs: Implements the low level command call, this needs to build the command structure
          and push it on the correct queue.
  
          :param command: Command name to execute supported by the node (ex: core.system, info.cpu, etc...)
                          check documentation for list of built in commands
          :param arguments: A dict of required command arguments depends on the command name.
          :param queue: command queue (commands on the same queue are executed sequentially)
          :param max_time: kill job server side if it exceeded this amount of seconds
          :param stream: If True, process stdout and stderr are pushed to a special queue (stream:<id>) so
              client can stream output
          :param tags: job tags
          :param id: job id. Generated if not supplied
          :return: Response object