Function assert_scheduled_num

dali/test/python/test_pool.py:89–92

(context, num_tasks)

def assert_scheduled_num(context, num_tasks):
    assert len(context.partially_received) == num_tasks
    assert len(context.scheduled_minibatches) == num_tasks
    assert len(context.task_queue) == num_tasks


start_methods = ["fork", "spawn"]