def install_flocker(nodes, package_source):
 return _run_on_all_nodes(nodes, task=(lambda node: sequence([task_install_flocker(distribution=node.distribution, package_source=package_source), task_install_docker_plugin(distribution=node.distribution, package_source=package_source)])))

def install_flocker ( nodes , package_source ) : return _run_on_all_nodes ( nodes , task = ( lambda node : sequence ( [ task_install_flocker ( distribution = node . distribution , package_source = package_source ) , task_install_docker_plugin ( distribution = node . distribution , package_source = package_source ) ] ) ) )
return an effect that installs a certain version of flocker on the given nodes .