test_contest_manager.py 文件源码

def test_worker(self, gen_id_mock, call_mock):
        call_mock.side_effect = TestContestManager._valid_subprocess_call
        ContestManager.tasks["poldo"] = { "generator": "/gen", "validator": "/val" }

        with patch("src.logger.Logger.error", side_effect=TestContestManager._stop_worker_loop):
            with patch("gevent.queue.Queue.put", side_effect=NotImplementedError("Stop loop")):
                with self.assertRaises(NotImplementedError) as ex:
                    ContestManager.worker("poldo")