// execute. Do this in a loop while submitting tasks between each
// component failure.
time.sleep(0.1)
worker_nodes = cluster.list_all_nodes()[1:]
assert len(worker_nodes) > 0
for node in worker_nodes:
process = node.all_processes[component_type][0].process
// Submit a round of tasks with many dependencies.
After Change
// execute. Do this in a loop while submitting tasks between each
// component failure.
time.sleep(0.1)
worker_nodes = get_other_nodes(cluster)
assert len(worker_nodes) > 0
for node in worker_nodes:
process = node.all_processes[component_type][0].process
// Submit a round of tasks with many dependencies.
