

def handle_process_state_change_event(self, headers, payload):
    msg = self.get_process_state_change_msg(headers, payload)
    if msg:
        self.write_stderr(('%s\n' % msg))
        self.batchmsgs.append(msg)

dataset/ETHPy150Open XiaoMi/minos/supervisor/superlance/process_state_monitor.py ProcessStateMonitor.handle_process_state_change_event/original