Method replace_call

tests/buffer/queue_test.py:270–286

()

        # should not be blocked
        def replace_call():
            asyncio.run(
                writer.write(
                    [
                        Experience(
                            tokens=torch.tensor([1, 2, 3]),
                            prompt_length=2,
                            info={"model_version": 4, "use_count": 0},
                        ),
                        Experience(
                            tokens=torch.tensor([1, 2, 3]),
                            prompt_length=2,
                            info={"model_version": 4, "use_count": 0},
                        ),
                    ]
                )
            )

        thread = threading.Thread(target=replace_call)
        thread.start()