def METHOD_NAME(op, device, **kwargs):
    @pipeline_def
    def pipeline_factory():
        data = fn.external_source(source=RandomBatch(), layout=test_data_layout, batch=True)
        return op(move_to(data, device), device=device, **kwargs)
    check_is_pipeline_stateless(pipeline_factory)