def METHOD_NAME(relay_server, wandb_init):
    with relay_server() as relay:
        run = wandb_init(settings=dict(console="off"))
        run.log({"a": 1})
        run.mark_preempting()
        # poll for message arrival
        for _ in range(3):
            preempting = relay.context.entries[run.id].get("preempting")
            if preempting:
                break
            time.sleep(1)
        assert any(preempting)
        run.finish()