code: def _disbatch_runner(self, chunk):
          '''
          Disbatch runner client commands
          '''
          full_return = chunk.pop('full_return', False)
          pub_data = self.saltclients['runner'](chunk)
          tag = pub_data['tag'] + '/ret'
          try:
              event = yield self.application.event_listener.get_event(self, tag=tag)
  
              # only return the return data
              ret = event if full_return else event['data']['return']
              raise tornado.gen.Return(ret)
          except TimeoutException:
              raise tornado.gen.Return('Timeout waiting for runner to execute'f _disbatch_runner(self, chunk):
          '''
          Disbatch runner client commands
          '''
          full_return = chunk.pop('full_return', False)
          pub_data = self.saltclients['runner'](chunk)
          tag = pub_data['tag'] + '/ret'
          try:
              event = yield self.application.event_listener.get_event(self, tag=tag)
  
              # only return the return data
              ret = event if full_return else event['data']['return']
              raise tornado.gen.Return(ret)
          except TimeoutException:
              raise tornado.gen.Return('Timeout waiting for runner to execute')
docs: Disbatch runner client commands