

def produce_status_update_task(self, input_queue):
    reactor.callInThread(self.produce_status_update_task_in_thread, input_queue)

dataset/ETHPy150Open XiaoMi/minos/owl/collector/management/commands/collect.py StatusUpdater.produce_status_update_task/original