def _discoro_cmd_reader(coro=None):
            coro.set_daemon()
            async_threads = asyncoro.AsyncThreadPool(1)
            while 1:
                yield coro.sleep(0.25)
                try:
                    _discoro_cmd = yield async_threads.async_task(
                        raw_input,
                        '\nEnter "status" to get status\n'
                          '  "close" to close current computation (kill any running jobs)\n'
                          '  "quit" to stop accepting new jobs and quit when done\n'
                          '  "terminate" to kill current jobs and quit: ')
                except:
                    _discoro_cmd = 'terminate'
                else:
                    _discoro_cmd = _discoro_cmd.strip().lower()

                print('')
                if _discoro_cmd == 'status' or _discoro_cmd == 'close':
                    for _discoro_server_info in _discoro_server_infos:
                        _discoro_server_info.Queue.put({'req': _discoro_cmd, 'auth': _discoro_auth})
                elif ('quit', 'terminate') in _discoro_cmd:
                    for _discoro_server_info in _discoro_server_infos:
                        _discoro_server_info.Queue.put({'req': _discoro_cmd, 'auth': _discoro_auth})
                    break
dataset/ETHPy150Open pgiri/asyncoro/py2/asyncoro/discoronode.py/_discoro_cmd_reader/swapped operands of `in`