def handle(self, *args, **options):
    gc.set_debug(gc.DEBUG_STATS)

    self.args = args
    self.options = options

    self.stdout.write("args: %r\n" % (args, ))
    self.stdout.write("options: %r\n" % options)

    self.collector_config = CollectorConfig(self.args, self.options)
    if self.options['clear_old_tasks']:
      self.clear_old_tasks()

    self.update_active_tasks()

    self.input_queue = multiprocessing.Queue()
    self.output_queue = multiprocessing.Queue()

    for idx in range(PROCESS_NUM):
      multiprocessing.Process(target=process_queue_task,
        args=(self.input_queue, self.output_queue)).start()

    self.fetch_metrics()
dataset/ETHPy150Open XiaoMi/minos/owl/collector/management/commands/collect.py/Command.handle/original