f37b6874523cdab4dc69118ff44b1bb8469a9217,ci/regression_test/stress_tests/test_many_tasks.py,,,#,47

Before Change

print("\tTotal time: {}".format(stage_2_time))
print("\tAverage iteration time: {}".format(
    sum(stage_2_iterations) / len(stage_2_iterations)))
print("\tMax iteration time: {}".format(max(stage_2_iterations)))
print("\tMin iteration time: {}".format(min(stage_2_iterations)))

print("Stage 3 results:")

After Change

// task will require O(N) queries. Since we limit the number of inflight
// requests, we will run into head of line blocking and we should be able to
// measure this timing.
num_tasks = int(ray.cluster_resources()["GPU"])
logger.info(f"Scheduling many tasks for spillback.")


@ray.remote(num_gpus=1)

Instances