Functions
def	mkname
def	rcmd
def	pinit
def	startcasapy
def	mkContResImgWorkaround
def	mkContResImgNotInUse
def	mksyscmdstr
def	cpmodelimg
def	rmimage
def	mkResOnly
def	setModelImgCoordsys
def	accumulateModel
def	setUpFlagger
def	setUpGaincal
def	setUpBandpass
def	setUpApplycal
def	setUpClean
def	pspectralline
def	pcontinuum
def	pcontinuumdebugger
Variables
string	PARALLEL_CASAPY_ROOT_DIR
string	PARALLEL_CONFIGFILES_DIR
string	PARALLEL_WORK_DIR
string	PARALLEL_BASE_ROOT_DIR

Function Documentation

def recipes.cluster.accumulateModel	(	iModel,
		modelimage,
		iatool = `ia`
	)

Definition at line 199 of file cluster.py.

References recipes.cluster.setUpFlagger().

Referenced by recipes.cluster.pcontinuum(), and recipes.cluster.pcontinuumdebugger().

def recipes.cluster.cpmodelimg	(	rmec,
		nodes,
		modelimage,
		rootdir = `PARALLEL_BASE_ROOT_DIR`,
		workdir = `PARALLEL_WORK_DIR`,
		imagebasename = `"ptest.model."`
	)

Definition at line 152 of file cluster.py.

References recipes.cluster.mkname().

Referenced by recipes.cluster.mksyscmdstr().

def recipes.cluster.mkContResImgNotInUse	(	rmec,
		nodes,
		iatool,
		rootdir = `PARALLEL_BASE_ROOT_DIR`,
		workdir = `PARALLEL_WORK_DIR`,
		imagebasename = `"ptest.cont.im."`,
		extension = `".residual"`,
		outimagename = `"dirtyavg.im"`
	)

Definition at line 125 of file cluster.py.

References recipes.cluster.mkname().

Referenced by recipes.cluster.mkContResImgWorkaround().

def recipes.cluster.mkContResImgWorkaround	(	rmec,
		nodes,
		iatool,
		rootdir = `PARALLEL_BASE_ROOT_DIR`,
		workdir = `PARALLEL_WORK_DIR`,
		imagebasename = `"ptest.cont.im."`,
		extension = `".residual"`,
		outimagename = `"dirtyavg.im"`
	)

Definition at line 69 of file cluster.py.

References recipes.cluster.mkContResImgNotInUse(), recipes.cluster.mkname(), and irc_cs_task_regression.sum.

Referenced by recipes.cluster.pcontinuum(), recipes.cluster.pcontinuumdebugger(), and recipes.cluster.startcasapy().

def recipes.cluster.mkname	(	node,
		rootdir,
		workdir,
		basename,
		ext,
		regex = `false`
	)

Definition at line 12 of file cluster.py.

Referenced by recipes.cluster.cpmodelimg(), recipes.cluster.mkContResImgNotInUse(), recipes.cluster.mkContResImgWorkaround(), recipes.cluster.pcontinuum(), recipes.cluster.pcontinuumdebugger(), recipes.cluster.setUpApplycal(), recipes.cluster.setUpBandpass(), recipes.cluster.setUpClean(), recipes.cluster.setUpFlagger(), and recipes.cluster.setUpGaincal().

def recipes.cluster.mkResOnly	(	rmec,
		nodes,
		configfile = `PARALLEL_CONFIGFILES_DIR+"clean_mfs_major.last"`,
		rootdir = `PARALLEL_BASE_ROOT_DIR`,
		workdir = `PARALLEL_WORK_DIR`,
		msbasename = `"pevla2_1h.16.ms-"`,
		imagebasename = `"ptest.cont.im."`
	)

Definition at line 177 of file cluster.py.

References recipes.cluster.setUpClean().

Referenced by recipes.cluster.pcontinuum(), recipes.cluster.pcontinuumdebugger(), and recipes.cluster.rmimage().

def recipes.cluster.mksyscmdstr ( cmd )

Definition at line 142 of file cluster.py.

References recipes.cluster.cpmodelimg().

def recipes.cluster.pcontinuum	(	mec,
		iatool,
		deconvtool,
		nodes,
		minoriter = `1000`,
		minorpermajor = `200`,
		majoriter = `5`,
		majorconfigfile = `PARALLEL_CONFIGFILES_DIR+"clean_mfs_major.last"`,
		minorconfigfile = `""`,
		msbasename = `"pevla2_1h.16.ms-"`,
		imagebasename = `"ptest.cont.im."`,
		rootdir = `PARALLEL_BASE_ROOT_DIR`,
		workdir = `PARALLEL_WORK_DIR`
	)

Definition at line 393 of file cluster.py.

References recipes.cluster.accumulateModel(), recipes.cluster.mkContResImgWorkaround(), recipes.cluster.mkname(), recipes.cluster.mkResOnly(), recipes.cluster.pcontinuumdebugger(), and recipes.cluster.setModelImgCoordsys().

Referenced by recipes.cluster.pspectralline().

def recipes.cluster.pcontinuumdebugger	(	mec,
		iatool,
		deconvtool,
		nodes,
		minorconfigfile,
		majorconfigfile,
		dowhat,
		rootdir = `PARALLEL_BASE_ROOT_DIR`,
		workdir = `PARALLEL_WORK_DIR`,
		msbasename = `"pevla2_1h.16.ms-"`,
		imagebasename = `"ptest.cont.im."`,
		minoriter = `100`,
		majoriter = `10`
	)

Definition at line 467 of file cluster.py.

References recipes.cluster.accumulateModel(), recipes.cluster.mkContResImgWorkaround(), recipes.cluster.mkname(), recipes.cluster.mkResOnly(), and recipes.cluster.setModelImgCoordsys().

Referenced by recipes.cluster.pcontinuum().

def recipes.cluster.pinit ( message = "Hello CASA Cluster" )

Definition at line 35 of file cluster.py.

def recipes.cluster.pspectralline	(	rmec,
		nodes,
		nchan,
		niter = `1000`,
		msbasename = `"pevla2_1h.16.ms-"`,
		imagebasename = `"ptest.cont.im."`,
		configfile = `PARALLEL_CONFIGFILES_DIR+"clean.last"`,
		rootdir = `PARALLEL_BASE_ROOT_DIR`,
		workdir = `PARALLEL_WORK_DIR`
	)

Definition at line 377 of file cluster.py.

References recipes.cluster.pcontinuum(), and recipes.cluster.setUpClean().

Referenced by recipes.cluster.setUpClean().

def recipes.cluster.rcmd	(	var,
		op,
		value
	)

Definition at line 26 of file cluster.py.

Referenced by recipes.cluster.setUpApplycal(), recipes.cluster.setUpBandpass(), recipes.cluster.setUpClean(), recipes.cluster.setUpFlagger(), recipes.cluster.setUpGaincal(), and recipes.cluster.startcasapy().

def recipes.cluster.rmimage	(	mec,
		imagename,
		doit = `false`
	)

Definition at line 162 of file cluster.py.

References recipes.cluster.mkResOnly().

def recipes.cluster.setModelImgCoordsys	(	modelimage,
		sourceimage,
		iatool = `ia`
	)

Definition at line 188 of file cluster.py.

Referenced by recipes.cluster.pcontinuum(), and recipes.cluster.pcontinuumdebugger().

def recipes.cluster.setUpApplycal	(	rmec,
		field = `""`,
		spw = `""`,
		gaintable = `['']`,
		interp = `['']`,
		rootdir = `PARALLEL_BASE_ROOT_DIR`,
		workdir = `PARALLEL_WORK_DIR`,
		msbasename = `"pevla2_1h.ms-"`,
		imagebasename = `"ptest.im."`
	)

Definition at line 315 of file cluster.py.

References recipes.cluster.mkname(), recipes.cluster.rcmd(), and recipes.cluster.setUpClean().

Referenced by recipes.cluster.setUpBandpass().

def recipes.cluster.setUpBandpass	(	rmec,
		nodes,
		caltable = `'BJones.tab'`,
		field = `'0'`,
		spw = `'0'`,
		solint = `'inf'`,
		gaintable = `''`,
		interp = `['nearest']`,
		configfile = `PARALLEL_CONFIGFILES_DIR+"pbandpass.last"`,
		rootdir = `PARALLEL_BASE_ROOT_DIR`,
		workdir = `PARALLEL_WORK_DIR`,
		msbasename = `"pevla2_1h.ms-"`
	)

Definition at line 281 of file cluster.py.

References recipes.cluster.mkname(), recipes.cluster.rcmd(), and recipes.cluster.setUpApplycal().

Referenced by recipes.cluster.setUpGaincal().

def recipes.cluster.setUpClean	(	rmec,
		nchan,
		niter = `1000`,
		nodes = `[1`,
		configfile = `PARALLEL_CONFIGFILES_DIR+"clean.last"`,
		rootdir = `PARALLEL_BASE_ROOT_DIR`,
		workdir = `PARALLEL_WORK_DIR`,
		msbasename = `"pevla2_1h.ms-"`,
		imagebasename = `"ptest.im."`
	)

Definition at line 347 of file cluster.py.

References recipes.cluster.mkname(), recipes.cluster.pspectralline(), and recipes.cluster.rcmd().

Referenced by recipes.cluster.mkResOnly(), recipes.cluster.pspectralline(), and recipes.cluster.setUpApplycal().

def recipes.cluster.setUpFlagger	(	rmec,
		nodes,
		mode = `"quack"`,
		configfile = `PARALLEL_CONFIGFILES_DIR+"pquack.last"`,
		rootdir = `PARALLEL_BASE_ROOT_DIR`,
		workdir = `PARALLEL_WORK_DIR`,
		msbasename = `"pevla2_1h.ms-"`
	)

Definition at line 224 of file cluster.py.

References recipes.cluster.mkname(), recipes.cluster.rcmd(), and recipes.cluster.setUpGaincal().

Referenced by recipes.cluster.accumulateModel().

def recipes.cluster.setUpGaincal	(	rmec,
		nodes,
		caltable = `'s0_0.gcal'`,
		field = `'0'`,
		spw = `'0'`,
		solint = `'10s'`,
		configfile = `PARALLEL_CONFIGFILES_DIR+"pgaincal.last"`,
		rootdir = `PARALLEL_BASE_ROOT_DIR`,
		workdir = `PARALLEL_WORK_DIR`,
		msbasename = `"pevla2_1h.ms-"`
	)