cluster.py File Reference

contains functionality for creating a cluste More...

Functions
def	nabu.computing.cluster.get_machines (machine_dir)
	gets the machines that reported in the machine directory More...
def	nabu.computing.cluster.read_cluster (filename)
	read a cluster file More...
def	nabu.computing.cluster.port_available (port)
	check if port is available

Detailed Description

contains functionality for creating a cluste

Function Documentation

get_machines()

def nabu.computing.cluster.get_machines

(

machine_dir

)

gets the machines that reported in the machine directory

Parameters

machine_dir	the directory where the machines are reporting
Returns	a dictionary with keys ps and worker and lists containing the machines as elements

read_cluster()

def nabu.computing.cluster.read_cluster

(

filename

)

read a cluster file

Parameters

filename

the cluster file

Returns

a dictionary with ps and worker containing a list of machines