tests.test_simplecluster.test_simplecluster Class Reference

Inheritance diagram for tests.test_simplecluster.test_simplecluster:

List of all members.

Public Member Functions
def	stopCluster
def	cleanUp
def	initCluster
def	createClusterFile
def	waitForFile
def	setUpFile
def	setUpFileCore
def	create_input
def	test1_defaultCluster
def	test2_availableResourcesCluster
def	test3_halfCPUCluster
def	test3_halfMemoryCluster
def	test4_monitoringDefault
def	test5_monitoringUser
def	test6_monitoringStandAlone
def	test7_bypassParallelProcessing
def	test8_IgnoreNullSelectionError
Public Attributes
	monitorFile
	vis
	ref
	aux
Static Public Attributes
string	projectname
string	clusterfile
string	monitorFile
	cluster
tuple	host
tuple	cwd
tuple	ncpu
	bypassParallelProcessing
string	vis
string	ref
string	aux

---

Detailed Description

Definition at line 15 of file test_simplecluster.py.

---

Member Function Documentation

def tests.test_simplecluster.test_simplecluster.cleanUp

(

self

)

Definition at line 44 of file test_simplecluster.py.

References tests.test_simplecluster.test_simplecluster.clusterfile, and tests.test_simplecluster.test_simplecluster.monitorFile.

Referenced by tests.test_simplecluster.test_simplecluster.initCluster(), and tests.test_simplecluster.test_simplecluster.stopCluster().

def tests.test_simplecluster.test_simplecluster.create_input	(		self,
			str_text,
			filename
	)

Save the string in a text file

Definition at line 111 of file test_simplecluster.py.

References tests.test_simplecluster.test_simplecluster.waitForFile().

Referenced by tests.test_simplecluster.test_flagdata_mms.test1_flagdata_list_return(), and tests.test_simplecluster.test_simplecluster.test7_bypassParallelProcessing().

def tests.test_simplecluster.test_simplecluster.createClusterFile	(		self,
			max_engines = 0.,
			max_memory = 0.,
			memory_per_engine = 512.
	)

Definition at line 73 of file test_simplecluster.py.

References tests.test_simplecluster.test_simplecluster.clusterfile, tests.test_simplecluster.test_simplecluster.cwd, tests.test_simplecluster.test_simplecluster.host, pCASA.subMS.host, and tests.test_simplecluster.test_simplecluster.waitForFile().

def tests.test_simplecluster.test_simplecluster.initCluster	(		self,
			userMonitorFile = "",
			max_engines = 0.,
			max_memory = 0.,
			memory_per_engine = 512.
	)

Definition at line 53 of file test_simplecluster.py.

References tests.test_bandpass.test_base.cleanUp(), tests.test_gaincal.test_base.cleanUp(), tests.test_simplecluster.test_simplecluster.cleanUp(), tests.test_simplecluster.test_simplecluster.cluster, and pCASA.pCASA.cluster.

Referenced by tests.test_simplecluster.test_flagdata_mms.setUp(), tests.test_simplecluster.test_setjy_mms.setUp(), tests.test_simplecluster.test_applycal_mms.setUp(), tests.test_simplecluster.test_uvcont_mms.setUp(), tests.test_simplecluster.test_simplecluster.test1_defaultCluster(), tests.test_simplecluster.test_simplecluster.test2_availableResourcesCluster(), tests.test_simplecluster.test_simplecluster.test3_halfCPUCluster(), tests.test_simplecluster.test_simplecluster.test3_halfMemoryCluster(), tests.test_simplecluster.test_simplecluster.test4_monitoringDefault(), tests.test_simplecluster.test_simplecluster.test5_monitoringUser(), and tests.test_simplecluster.test_simplecluster.test6_monitoringStandAlone().

def tests.test_simplecluster.test_simplecluster.setUpFile	(		self,
			file,
			type_file
	)

Definition at line 87 of file test_simplecluster.py.

References tests.test_simplecluster.test_simplecluster.setUpFileCore().

Referenced by tests.test_simplecluster.test_flagdata_mms.setUp(), tests.test_simplecluster.test_setjy_mms.setUp(), tests.test_simplecluster.test_applycal_mms.setUp(), tests.test_simplecluster.test_uvcont_mms.setUp(), tests.test_simplecluster.test_simplecluster.test7_bypassParallelProcessing(), and tests.test_simplecluster.test_simplecluster.test8_IgnoreNullSelectionError().

def tests.test_simplecluster.test_simplecluster.setUpFileCore	(		self,
			file,
			type_file
	)

Definition at line 102 of file test_simplecluster.py.

Referenced by tests.test_simplecluster.test_simplecluster.setUpFile().

def tests.test_simplecluster.test_simplecluster.stopCluster

(

self

)

Definition at line 38 of file test_simplecluster.py.

References tests.test_bandpass.test_base.cleanUp(), tests.test_gaincal.test_base.cleanUp(), and tests.test_simplecluster.test_simplecluster.cleanUp().

Referenced by tests.test_simplecluster.test_flagdata_mms.tearDown(), tests.test_simplecluster.test_setjy_mms.tearDown(), tests.test_simplecluster.test_applycal_mms.tearDown(), tests.test_simplecluster.test_uvcont_mms.tearDown(), tests.test_simplecluster.test_simplecluster.test1_defaultCluster(), tests.test_simplecluster.test_simplecluster.test2_availableResourcesCluster(), tests.test_simplecluster.test_simplecluster.test3_halfCPUCluster(), tests.test_simplecluster.test_simplecluster.test3_halfMemoryCluster(), tests.test_simplecluster.test_simplecluster.test4_monitoringDefault(), tests.test_simplecluster.test_simplecluster.test5_monitoringUser(), tests.test_simplecluster.test_simplecluster.test6_monitoringStandAlone(), and tests.test_simplecluster.test_simplecluster.test8_IgnoreNullSelectionError().

def tests.test_simplecluster.test_simplecluster.test1_defaultCluster

(

self

)

Test 1: Create a default cluster

Definition at line 133 of file test_simplecluster.py.

References tests.test_simplecluster.test_simplecluster.cwd, tests.test_simplecluster.test_simplecluster.host, pCASA.subMS.host, tests.test_simplecluster.test_simplecluster.initCluster(), tests.test_simplecluster.test_simplecluster.ncpu, and tests.test_simplecluster.test_simplecluster.stopCluster().

def tests.test_simplecluster.test_simplecluster.test2_availableResourcesCluster

(

self

)

Test 2: Create a custom cluster to use all the available resources

Definition at line 146 of file test_simplecluster.py.

References tests.test_simplecluster.test_simplecluster.cwd, tests.test_simplecluster.test_simplecluster.host, pCASA.subMS.host, tests.test_simplecluster.test_simplecluster.initCluster(), tests.test_simplecluster.test_simplecluster.ncpu, and tests.test_simplecluster.test_simplecluster.stopCluster().

def tests.test_simplecluster.test_simplecluster.test3_halfCPUCluster

(

self

)

Test 3: Create a custom cluster to use half of available CPU capacity

Definition at line 159 of file test_simplecluster.py.

References tests.test_simplecluster.test_simplecluster.cwd, tests.test_simplecluster.test_simplecluster.host, pCASA.subMS.host, tests.test_simplecluster.test_simplecluster.initCluster(), tests.test_simplecluster.test_simplecluster.ncpu, and tests.test_simplecluster.test_simplecluster.stopCluster().

def tests.test_simplecluster.test_simplecluster.test3_halfMemoryCluster

(

self

)

Test 3: Create a custom cluster to use half of available RAM memory

Definition at line 172 of file test_simplecluster.py.

References tests.test_simplecluster.test_simplecluster.cwd, tests.test_simplecluster.test_simplecluster.host, pCASA.subMS.host, tests.test_simplecluster.test_simplecluster.initCluster(), and tests.test_simplecluster.test_simplecluster.stopCluster().

def tests.test_simplecluster.test_simplecluster.test4_monitoringDefault

(

self

)

Test 4: Check default monitoring file exists

Definition at line 184 of file test_simplecluster.py.

References tests.test_simplecluster.test_simplecluster.initCluster(), and tests.test_simplecluster.test_simplecluster.stopCluster().

def tests.test_simplecluster.test_simplecluster.test5_monitoringUser

(

self

)

Test 5: Check custom monitoring file exists

Definition at line 207 of file test_simplecluster.py.

References tests.test_simplecluster.test_simplecluster.initCluster(), and tests.test_simplecluster.test_simplecluster.stopCluster().

def tests.test_simplecluster.test_simplecluster.test6_monitoringStandAlone

(

self

)

Test 6: Check the dict structure of the stand-alone method 

Definition at line 230 of file test_simplecluster.py.

References tests.test_simplecluster.test_simplecluster.host, pCASA.subMS.host, tests.test_simplecluster.test_simplecluster.initCluster(), and tests.test_simplecluster.test_simplecluster.stopCluster().

def tests.test_simplecluster.test_simplecluster.test7_bypassParallelProcessing

(

self

)

Test 7: Bypass Parallel Processing mode 

Definition at line 250 of file test_simplecluster.py.

References tests.test_simplecluster.test_simplecluster.bypassParallelProcessing, tests.test_simplecluster.test_simplecluster.create_input(), tests.test_simplecluster.test_simplecluster.setUpFile(), setjy_helper.ss_setjy_helper.vis, tests.test_pcasa.pcasa_test.vis, tests.test_agentflagger.test_base.vis, tests.test_listpartition.test_base.vis, tests.test_simplecluster.test_simplecluster.vis, tests.test_flagcmd.test_base.vis, tests.test_flagdata.test_base.vis, task_plotuv.UVPlotInfo.vis, and cleanhelper.cleanhelper.vis.

def tests.test_simplecluster.test_simplecluster.test8_IgnoreNullSelectionError

(

self

)

Test 8: Check that NullSelection errors happening for some sub-MSs are ignored  

Note: In this test we also check simple_cluster initialization via ParallelTaskHelper  

Definition at line 297 of file test_simplecluster.py.

References tests.test_simplecluster.test_simplecluster.cluster, pCASA.pCASA.cluster, tests.test_simplecluster.test_simplecluster.setUpFile(), tests.test_simplecluster.test_simplecluster.stopCluster(), tests.test_pcasa.pcasa_test.vis, setjy_helper.ss_setjy_helper.vis, tests.test_agentflagger.test_base.vis, tests.test_listpartition.test_base.vis, tests.test_simplecluster.test_simplecluster.vis, tests.test_flagcmd.test_base.vis, tests.test_flagdata.test_base.vis, task_plotuv.UVPlotInfo.vis, and cleanhelper.cleanhelper.vis.

def tests.test_simplecluster.test_simplecluster.waitForFile	(		self,
			file,
			seconds
	)

Definition at line 81 of file test_simplecluster.py.

Referenced by tests.test_simplecluster.test_simplecluster.create_input(), and tests.test_simplecluster.test_simplecluster.createClusterFile().

---

Member Data Documentation

string tests.test_simplecluster.test_simplecluster.aux [static]

Definition at line 36 of file test_simplecluster.py.

Referenced by tests.test_simplecluster.test_applycal_mms.tearDown(), and tests.test_simplecluster.test_applycal_mms.test1_applycal_fluxscale_gcal_bcal().

tests.test_simplecluster.test_simplecluster.aux

Definition at line 100 of file test_simplecluster.py.

tests.test_simplecluster.test_simplecluster.bypassParallelProcessing [static]

Definition at line 30 of file test_simplecluster.py.

Referenced by tests.test_simplecluster.test_flagdata_mms.setUp(), tests.test_simplecluster.test_setjy_mms.setUp(), tests.test_simplecluster.test_applycal_mms.setUp(), tests.test_simplecluster.test_uvcont_mms.setUp(), tests.test_simplecluster.test_flagdata_mms.tearDown(), tests.test_simplecluster.test_setjy_mms.tearDown(), tests.test_simplecluster.test_applycal_mms.tearDown(), tests.test_simplecluster.test_uvcont_mms.tearDown(), and tests.test_simplecluster.test_simplecluster.test7_bypassParallelProcessing().

tests.test_simplecluster.test_simplecluster.cluster [static]

Definition at line 20 of file test_simplecluster.py.

Referenced by tests.test_simplecluster.test_simplecluster.initCluster(), and tests.test_simplecluster.test_simplecluster.test8_IgnoreNullSelectionError().

string tests.test_simplecluster.test_simplecluster.clusterfile [static]

Definition at line 18 of file test_simplecluster.py.

Referenced by tests.test_simplecluster.test_simplecluster.cleanUp(), and tests.test_simplecluster.test_simplecluster.createClusterFile().

tuple tests.test_simplecluster.test_simplecluster.cwd [static]

Definition at line 24 of file test_simplecluster.py.

Referenced by tests.test_simplecluster.test_simplecluster.createClusterFile(), tests.test_simplecluster.test_simplecluster.test1_defaultCluster(), tests.test_simplecluster.test_simplecluster.test2_availableResourcesCluster(), tests.test_simplecluster.test_simplecluster.test3_halfCPUCluster(), and tests.test_simplecluster.test_simplecluster.test3_halfMemoryCluster().

tuple tests.test_simplecluster.test_simplecluster.host [static]

Definition at line 23 of file test_simplecluster.py.

Referenced by tests.test_simplecluster.test_simplecluster.createClusterFile(), tests.test_simplecluster.test_simplecluster.test1_defaultCluster(), tests.test_simplecluster.test_simplecluster.test2_availableResourcesCluster(), tests.test_simplecluster.test_simplecluster.test3_halfCPUCluster(), tests.test_simplecluster.test_simplecluster.test3_halfMemoryCluster(), and tests.test_simplecluster.test_simplecluster.test6_monitoringStandAlone().

string tests.test_simplecluster.test_simplecluster.monitorFile [static]

Definition at line 19 of file test_simplecluster.py.

Referenced by tests.test_simplecluster.test_simplecluster.cleanUp().

tests.test_simplecluster.test_simplecluster.monitorFile

Definition at line 59 of file test_simplecluster.py.

tuple tests.test_simplecluster.test_simplecluster.ncpu [static]

Definition at line 25 of file test_simplecluster.py.

Referenced by tests.test_simplecluster.test_simplecluster.test1_defaultCluster(), tests.test_simplecluster.test_simplecluster.test2_availableResourcesCluster(), and tests.test_simplecluster.test_simplecluster.test3_halfCPUCluster().

string tests.test_simplecluster.test_simplecluster.projectname [static]

Definition at line 17 of file test_simplecluster.py.

string tests.test_simplecluster.test_simplecluster.ref [static]

Definition at line 35 of file test_simplecluster.py.

Referenced by tests.test_smoothcal.smoothcal_test.setUp(), tests.test_smoothcal.smoothcal_test.tearDown(), tests.test_simplecluster.test_applycal_mms.tearDown(), tests.test_simplecluster.test_uvcont_mms.tearDown(), tests.test_smoothcal.smoothcal_test.test10(), tests.test_simplecluster.test_applycal_mms.test1_applycal_fluxscale_gcal_bcal(), and tests.test_simplecluster.test_uvcont_mms.test1_uvcont_single_spw().

tests.test_simplecluster.test_simplecluster.ref

Definition at line 98 of file test_simplecluster.py.

Referenced by tests.test_smoothcal.smoothcal_test.setUp(), tests.test_smoothcal.smoothcal_test.tearDown(), and tests.test_smoothcal.smoothcal_test.test10().

string tests.test_simplecluster.test_simplecluster.vis [static]

Definition at line 34 of file test_simplecluster.py.

Referenced by tests.test_simplecluster.test_flagdata_mms.tearDown(), tests.test_simplecluster.test_setjy_mms.tearDown(), tests.test_simplecluster.test_applycal_mms.tearDown(), tests.test_simplecluster.test_uvcont_mms.tearDown(), tests.test_simplecluster.test_applycal_mms.test1_applycal_fluxscale_gcal_bcal(), tests.test_simplecluster.test_flagdata_mms.test1_flagdata_list_return(), tests.test_simplecluster.test_setjy_mms.test1_setjy_scratchless_mode_single_model(), tests.test_simplecluster.test_uvcont_mms.test1_uvcont_single_spw(), tests.test_simplecluster.test_setjy_mms.test2_setjy_scratchless_mode_multiple_model(), tests.test_simplecluster.test_setjy_mms.test3_setjy_scratch_mode_single_model(), tests.test_simplecluster.test_setjy_mms.test4_setjy_scratch_mode_multiple_model(), tests.test_simplecluster.test_simplecluster.test7_bypassParallelProcessing(), and tests.test_simplecluster.test_simplecluster.test8_IgnoreNullSelectionError().

tests.test_simplecluster.test_simplecluster.vis

Definition at line 96 of file test_simplecluster.py.

---

The documentation for this class was generated from the following file:

• tests/test_simplecluster.py