

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