Function policy_worker

codeclash/arenas/scml/runtime/run_scml.py:187–220

(
    command_queue: mp.Queue, result_queue: mp.Queue, startup_queue: mp.Queue, player_name: str, path: str
)

def policy_worker(
    command_queue: mp.Queue, result_queue: mp.Queue, startup_queue: mp.Queue, player_name: str, path: str
) -> None:
    try:
        module = load_policy_module(player_name, path)
    except BaseException as exc:
        startup_queue.put(
            {
                "error": f"{type(exc).__name__}: {exc}",
                "traceback": traceback.format_exc(limit=5),
            }
        )
        return
    startup_queue.put({"ready": True})

    while True:
        try:
            request = command_queue.get()
        except (EOFError, KeyboardInterrupt):
            return
        if request is None:
            return
        request_id = request["request_id"]
        try:
            decision = module.decide(request["observation"])
            result_queue.put({"request_id": request_id, "decision": decision})
        except BaseException as exc:
            result_queue.put(
                {
                    "request_id": request_id,
                    "error": f"{type(exc).__name__}: {exc}",
                    "traceback": traceback.format_exc(limit=5),
                }
            )


class PolicyController: