Function func

dali/test/python/operator_2/test_python_function.py:675–677

(x)

def test_delete_pipe_while_function_running():
    def func(x):
        time.sleep(0.02)
        return x

    for i in range(5):
        with Pipeline(batch_size=1, num_threads=1, device_id=None) as pipe: