Inheritance diagram for task_partition.PartitionHelper:

Public Member Functions
def	__init__
def	initialize
def	generateJobs
def	postExecution
Public Attributes
	outputBase
	dataDir
	ptab
	handle the POINTING and SYSCAL tables ##
	stab
	pointingisempty
	makepointinglinks
	pwriteaccess
	syscalisempty
	makesyscallinks
	swriteaccess
Private Member Functions
def	_createCalMSCommand
def	_createPrimarySplitCommand
def	_createScanSeparationCommands
def	_createSPWSeparationCommands
def	_createDefaultSeparationCommands
def	_selectMS
def	_getSPWList
def	_getScanList
def	_getSelectionFilter
def	_getCalibrationFilter
def	__generateFilter
def	__partition
Private Attributes
	_calScanList
	_selectionScanList
	_msTool
	_tbTool
	_sequential_return_list

Detailed Description

Definition at line 12 of file task_partition.py.

Constructor & Destructor Documentation

def task_partition.PartitionHelper.__init__	(	self,
		args = `{}`
	)

Reimplemented in tests.test_partitionHelper.PartitionHelperTest.

Definition at line 13 of file task_partition.py.

Member Function Documentation

def task_partition.PartitionHelper.__generateFilter	(	self,
		selectionPairs
	)	`[private]`

Definition at line 460 of file task_partition.py.

References parallel.parallel_task_helper.ParallelTaskHelper._arg.

Referenced by task_partition.PartitionHelper._getCalibrationFilter(), and task_partition.PartitionHelper._getSelectionFilter().

def task_partition.PartitionHelper.__partition	(	self,
		lst,
		n
	)	`[private]`

This method will split the list lst into "n" almost equal parts
if lst is none, then we assume an empty list

Definition at line 469 of file task_partition.py.

References task_partition.partition().

Referenced by task_partition.PartitionHelper._createDefaultSeparationCommands(), task_partition.PartitionHelper._createScanSeparationCommands(), and task_partition.PartitionHelper._createSPWSeparationCommands().

def task_partition.PartitionHelper._createCalMSCommand ( self ) [private]

Create a command which will generate a MS with only those subMSs
in the selected calibration

Definition at line 126 of file task_partition.py.

References parallel.parallel_task_helper.ParallelTaskHelper._arg, task_partition.PartitionHelper._calScanList, task_partition.PartitionHelper._getScanList(), task_partition.PartitionHelper._selectMS(), parallel.parallel_task_helper.ParallelTaskHelper._taskName, task_partition.PartitionHelper.dataDir, and task_partition.PartitionHelper.outputBase.

Referenced by task_partition.PartitionHelper.generateJobs().

def task_partition.PartitionHelper._createDefaultSeparationCommands ( self ) [private]

Definition at line 211 of file task_partition.py.

References task_partition.PartitionHelper.__partition(), parallel.parallel_task_helper.ParallelTaskHelper._arg, task_partition.PartitionHelper._getScanList(), task_partition.PartitionHelper._getSPWList(), task_partition.PartitionHelper._selectionScanList, task_partition.PartitionHelper._selectMS(), parallel.parallel_task_helper.ParallelTaskHelper._taskName, task_partition.PartitionHelper.dataDir, and task_partition.PartitionHelper.outputBase.

Referenced by task_partition.PartitionHelper._createPrimarySplitCommand(), and tests.test_partitionHelper.PartitionHelperTest.testDefaultSeparationCommands().

def task_partition.PartitionHelper._createPrimarySplitCommand ( self ) [private]

Definition at line 147 of file task_partition.py.

References parallel.parallel_task_helper.ParallelTaskHelper._arg, task_partition.PartitionHelper._createDefaultSeparationCommands(), task_partition.PartitionHelper._createScanSeparationCommands(), task_partition.PartitionHelper._createSPWSeparationCommands(), parallel.parallel_task_helper.ParallelTaskHelper._taskName, and parallel.parallel_task_helper.ParallelTaskHelper.listToCasaString().

Referenced by task_partition.PartitionHelper.generateJobs().

def task_partition.PartitionHelper._createScanSeparationCommands ( self ) [private]

Definition at line 165 of file task_partition.py.

References task_partition.PartitionHelper.__partition(), parallel.parallel_task_helper.ParallelTaskHelper._arg, task_partition.PartitionHelper._getScanList(), task_partition.PartitionHelper._selectionScanList, task_partition.PartitionHelper._selectMS(), parallel.parallel_task_helper.ParallelTaskHelper._taskName, task_partition.PartitionHelper.dataDir, parallel.parallel_task_helper.ParallelTaskHelper.listToCasaString(), and task_partition.PartitionHelper.outputBase.

Referenced by task_partition.PartitionHelper._createPrimarySplitCommand().

def task_partition.PartitionHelper._createSPWSeparationCommands ( self ) [private]

Definition at line 188 of file task_partition.py.

References task_partition.PartitionHelper.__partition(), parallel.parallel_task_helper.ParallelTaskHelper._arg, task_partition.PartitionHelper._getSPWList(), task_partition.PartitionHelper._selectionScanList, task_partition.PartitionHelper._selectMS(), parallel.parallel_task_helper.ParallelTaskHelper._taskName, task_partition.PartitionHelper.dataDir, parallel.parallel_task_helper.ParallelTaskHelper.listToCasaString(), and task_partition.PartitionHelper.outputBase.

Referenced by task_partition.PartitionHelper._createPrimarySplitCommand(), and tests.test_partitionHelper.PartitionHelperTest.testSpwSeparationCommands().

def task_partition.PartitionHelper._getCalibrationFilter ( self ) [private]

Definition at line 449 of file task_partition.py.

References task_partition.PartitionHelper.__generateFilter(), and parallel.parallel_task_helper.ParallelTaskHelper._arg.

Referenced by task_partition.PartitionHelper._selectMS().

def task_partition.PartitionHelper._getScanList ( self ) [private]

This method returns the scan list from the current ms.  Be careful
about having selection already done when you call this.

Reimplemented in tests.test_partitionHelper.PartitionHelperTest.

Definition at line 326 of file task_partition.py.

References task_partition.PartitionHelper._msTool, and task_partition.PartitionHelper._selectMS().

Referenced by task_partition.PartitionHelper._createCalMSCommand(), task_partition.PartitionHelper._createDefaultSeparationCommands(), task_partition.PartitionHelper._createScanSeparationCommands(), task_partition.PartitionHelper._selectMS(), and tests.test_partitionHelper.PartitionHelperTest.testSpwSeparationCommands().

def task_partition.PartitionHelper._getSelectionFilter ( self ) [private]

Definition at line 433 of file task_partition.py.

References task_partition.PartitionHelper.__generateFilter().

Referenced by task_partition.PartitionHelper._selectMS().

def task_partition.PartitionHelper._getSPWList ( self ) [private]

This method returns the spectral window list from the current
ms.  Be careful about having selection already done when you call this.

Reimplemented in tests.test_partitionHelper.PartitionHelperTest.

Definition at line 311 of file task_partition.py.

References task_partition.PartitionHelper._msTool, task_partition.PartitionHelper._selectMS(), and tests.test_imcontsub.list.

Referenced by task_partition.PartitionHelper._createDefaultSeparationCommands(), and task_partition.PartitionHelper._createSPWSeparationCommands().

def task_partition.PartitionHelper._selectMS	(	self,
		doCalibrationSelection = `False`
	)	`[private]`

This method will open the MS and ensure whatever selection critera
have been requested are honored.

If doCalibrationSelection is true then the MS is selected to the
calibration criteria.  If scanList is not None then it used as the
scan selectior criteria.

Reimplemented in tests.test_partitionHelper.PartitionHelperTest.

Definition at line 256 of file task_partition.py.

References parallel.parallel_task_helper.ParallelTaskHelper._arg, task_partition.PartitionHelper._calScanList, task_partition.PartitionHelper._getCalibrationFilter(), task_partition.PartitionHelper._getScanList(), task_partition.PartitionHelper._getSelectionFilter(), task_partition.PartitionHelper._msTool, task_partition.PartitionHelper._selectionScanList, and taskinit.mstool.

Referenced by task_partition.PartitionHelper._createCalMSCommand(), task_partition.PartitionHelper._createDefaultSeparationCommands(), task_partition.PartitionHelper._createScanSeparationCommands(), task_partition.PartitionHelper._createSPWSeparationCommands(), task_partition.PartitionHelper._getScanList(), task_partition.PartitionHelper._getSPWList(), and tests.test_partitionHelper.PartitionHelperTest.testSpwSeparationCommands().

def task_partition.PartitionHelper.generateJobs ( self )

This method overrides the method in the TaskHelper baseclass

Reimplemented from parallel.parallel_task_helper.ParallelTaskHelper.

Definition at line 112 of file task_partition.py.

References parallel.parallel_task_helper.ParallelTaskHelper._arg, task_partition.PartitionHelper._createCalMSCommand(), and task_partition.PartitionHelper._createPrimarySplitCommand().

def task_partition.PartitionHelper.initialize ( self )

This method will prepare the system for working, in particular:
   * Open the input MS as a msTool
   * Create the Output Directory and the Data subdirectory
   * Populate the global data selection filter (if necessary)

Reimplemented from parallel.parallel_task_helper.ParallelTaskHelper.

Definition at line 20 of file task_partition.py.

References parallel.parallel_task_helper.ParallelTaskHelper._arg.

Referenced by tests.test_uvcontsub3.zeroth.setUp(), tests.test_uvcontsub.zeroth.setUp(), tests.test_uvcontsub3.fourth.setUp(), tests.test_split.SplitChecker.setUp(), tests.test_uvcontsub.fourth.setUp(), tests.test_uvcontsub3.combspw.setUp(), tests.test_uvcontsub3.knowncombspw.setUp(), and tests.test_uvcontsub.combspw.setUp().

def task_partition.PartitionHelper.postExecution ( self )

This overrides the post execution portion of the task helper
in this case we probably need to generate the output reference
ms.

Reimplemented from parallel.parallel_task_helper.ParallelTaskHelper.

Definition at line 343 of file task_partition.py.

References parallel.parallel_task_helper.ParallelTaskHelper._arg, parallel.parallel_task_helper.ParallelTaskHelper._sequential_return_list, task_partition.PartitionHelper.dataDir, task_partition.PartitionHelper.pointingisempty, task_partition.PartitionHelper.ptab, task_partition.PartitionHelper.pwriteaccess, task_partition.PartitionHelper.stab, task_partition.PartitionHelper.swriteaccess, and task_partition.PartitionHelper.syscalisempty.

Member Data Documentation

task_partition.PartitionHelper._calScanList [private]

Reimplemented in tests.test_partitionHelper.PartitionHelperTest.

Definition at line 15 of file task_partition.py.

Referenced by task_partition.PartitionHelper._createCalMSCommand(), task_partition.PartitionHelper._selectMS(), tests.test_partitionHelper.PartitionHelperTest._selectMS(), and tests.test_partitionHelper.PartitionHelperTest.testSpwSeparationCommands().

task_partition.PartitionHelper._msTool [private]

Definition at line 17 of file task_partition.py.

Referenced by task_partition.PartitionHelper._getScanList(), task_partition.PartitionHelper._getSPWList(), and task_partition.PartitionHelper._selectMS().

task_partition.PartitionHelper._selectionScanList [private]

Reimplemented in tests.test_partitionHelper.PartitionHelperTest.

Definition at line 16 of file task_partition.py.

Referenced by task_partition.PartitionHelper._createDefaultSeparationCommands(), task_partition.PartitionHelper._createScanSeparationCommands(), task_partition.PartitionHelper._createSPWSeparationCommands(), task_partition.PartitionHelper._selectMS(), and tests.test_partitionHelper.PartitionHelperTest._selectMS().

task_partition.PartitionHelper._sequential_return_list [private]

Reimplemented from parallel.parallel_task_helper.ParallelTaskHelper.

Definition at line 366 of file task_partition.py.

task_partition.PartitionHelper._tbTool [private]

Definition at line 18 of file task_partition.py.

task_partition.PartitionHelper.dataDir

Reimplemented in tests.test_partitionHelper.PartitionHelperTest.

Definition at line 51 of file task_partition.py.

Referenced by task_partition.PartitionHelper._createCalMSCommand(), task_partition.PartitionHelper._createDefaultSeparationCommands(), task_partition.PartitionHelper._createScanSeparationCommands(), task_partition.PartitionHelper._createSPWSeparationCommands(), task_partition.PartitionHelper.postExecution(), tests.test_partitionHelper.PartitionHelperTest.testDefaultSeparationCommands(), and tests.test_partitionHelper.PartitionHelperTest.testSpwSeparationCommands().

task_partition.PartitionHelper.makepointinglinks

Definition at line 66 of file task_partition.py.

task_partition.PartitionHelper.makesyscallinks

Definition at line 76 of file task_partition.py.

task_partition.PartitionHelper.outputBase

Reimplemented in tests.test_partitionHelper.PartitionHelperTest.

Definition at line 44 of file task_partition.py.

Referenced by task_partition.PartitionHelper._createCalMSCommand(), task_partition.PartitionHelper._createDefaultSeparationCommands(), task_partition.PartitionHelper._createScanSeparationCommands(), task_partition.PartitionHelper._createSPWSeparationCommands(), tests.test_partitionHelper.PartitionHelperTest.testDefaultSeparationCommands(), and tests.test_partitionHelper.PartitionHelperTest.testSpwSeparationCommands().

task_partition.PartitionHelper.pointingisempty

Definition at line 65 of file task_partition.py.

Referenced by task_partition.PartitionHelper.postExecution().

task_partition.PartitionHelper.ptab

handle the POINTING and SYSCAL tables ##

Definition at line 59 of file task_partition.py.

Referenced by task_partition.PartitionHelper.postExecution().

task_partition.PartitionHelper.pwriteaccess

Definition at line 67 of file task_partition.py.

Referenced by task_partition.PartitionHelper.postExecution().

task_partition.PartitionHelper.stab

Definition at line 60 of file task_partition.py.

Referenced by task_partition.PartitionHelper.postExecution().

task_partition.PartitionHelper.swriteaccess

Definition at line 77 of file task_partition.py.

Referenced by task_partition.PartitionHelper.postExecution().

task_partition.PartitionHelper.syscalisempty

Definition at line 75 of file task_partition.py.

Referenced by task_partition.PartitionHelper.postExecution().

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

task_partition.py

Public Member Functions

Public Attributes

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation