def check_components_alive(cluster, component_type, check_component_alive):
Check that a given component type is alive on all worker nodes.
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
if check_component_alive:
After Change
def check_components_alive(cluster, component_type, check_component_alive):
Check that a given component type is alive on all worker nodes.
worker_nodes = get_other_nodes(cluster)
assert len(worker_nodes) > 0
for node in worker_nodes:
process = node.all_processes[component_type][0].process
if check_component_alive:
