code: def batch_work(self):
          
  
          while True:
              gen = collect_fragment(self._stop_event, self.config['AGORA'])
              for collector, (t, s, p, o) in gen:
                  for task in _batch_tasks:
                      task(collector, (t, s, p, o), self._stop_event)
                  if self._stop_event.isSet():
                      return
              for task in _batch_tasks:
                  task(None, None, self._stop_event)
              time.sleep(10)
docs: Method to be executed in batch mode for collecting the required fragment (composite)
          and then other custom tasks.
          :return: