def METHOD_NAME(src_device, gen_device):
    with torch.cuda.stream(torch.cuda.Stream()):
        for attempt in range(10):
            t0 = torch.tensor([attempt * 100 + 1.5], dtype=torch.float32, device=gen_device)
            increment = torch.tensor([10], dtype=torch.float32, device=gen_device)
            pipe = Pipeline(1, 3, 0)
            def gen_batch():
                nonlocal t0
                t0 += increment
                return [to_dlpack(t0)]
            pipe.set_outputs(fn.external_source(source=gen_batch, device=src_device,
                                                cuda_stream=torch.cuda.current_stream()))
            pipe.build()
            for i in range(10):
                check_output(pipe.run(),
                             [np.array([attempt * 100 + (i + 1) * 10 + 1.5], dtype=np.float32)])