Package wsatools :: Module SourceMerger :: Class SynopticMerger
[hide private]

Class SynopticMerger

source code


Create/update merged synoptic source catalogue for a given programme.

Nested Classes [hide private]
    Nested Errors and Exceptions

Inherited from DbConnect.CuSession.CuSession: CuError

Instance Methods [hide private]
 
_onRun(self)
Create/update merged source catalogue.
source code
 
_checkFrameSet(self, frameSet)
Checks frame set against current mergelog
source code
 
_checkMissingFrameSets(self)
Are there any existing frame sets not in the current lists
source code
 
_deleteOldFrameSets(self)
Remove old frame sets.
source code
 
_getMergeLogInfo(self)
Creates view of current merge log
source code
list(tuple(int, int))
_getProgFilters(self)
Returns: List of filter IDs and number of passes for the programme.
source code
 
_ingestMergeLogOnly(self, ingester)
Write the updated merge log of new (plus updated) frame sets (new frame sets flagged using the merge log attribute "new") to a CSV file.
source code
 
_insertDefaultRows(self)
Inserts default rows for every frame into synoptic source table.
source code
list(tuple)
_makeNewFrameSets(self)
Creates new frame sets as appropriate based on available intermediate stack frames.
source code
 
_selectBestMfIDs(self, frameSetInfo)
Chooses best mfIDs to match time info
source code
 
_setProgTableNames(self)
Initialises table name member variables for current programme.
source code

Inherited from SourceMerger: deprecateOldFrameSets, mergeSources, reseamSources

Inherited from DbConnect.CuSession.CuSession: __del__, __init__, logBrokenFile, run

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

Static Methods [hide private]

Inherited from DbConnect.CuSession.CuSession: logException

Class Variables [hide private]
  commencementMessage = 'Synoptic source merging...'
Message to log at the commencement of source merging.
  pairingCriterion = 0.8
Tight merging criterion because sources should not move in short space of time.
  frameSetChunkSize = 150
Number of frame sets in each chunk.
  cuNum = 6
Curation task number.
  _isVerbose = False
Turns off logging for certain sub-classes only.
  maxProdID = None
Maximum product ID to include in merged frame sets.
  minProdID = None
Minimum product ID to include in merged frame sets.
  prepareOnly = False
Only prepare the frame sets and update mergelog, without source merging?
  skipQualityCheck = False
Override quality bit flag check?
  recreate = False
Recreate from scratch
  _goodFrameSets = []
  _incompFrameSets = []
  _deprecFrameSets = []
  _newFrameSets = []

Inherited from SourceMerger: continueCompleteReseam, dateRange, doCompleteReseam, freeCacheInterval, minEpochSep, seamErrorBitMask, seamingPairCriterion, swVersion

Inherited from DbConnect.CuSession.CuSession: archive, comment, cuEventID, curator, eTypes, isDayStampedLog, onlyNonSurveys, onlySurveys, programme, programmeID, resultsFilePathName, shareFileID, sysc

Properties [hide private]

Inherited from object: __class__

Method Details [hide private]

_onRun(self)

source code 

Create/update merged source catalogue.

Overrides: DbConnect.CuSession.CuSession._onRun

_getProgFilters(self)

source code 
Returns: list(tuple(int, int))
List of filter IDs and number of passes for the programme.
Overrides: SourceMerger._getProgFilters

_makeNewFrameSets(self)

source code 

Creates new frame sets as appropriate based on available intermediate stack frames.

Returns: list(tuple)
List of new frame sets.

_setProgTableNames(self)

source code 

Initialises table name member variables for current programme.

Overrides: SourceMerger._setProgTableNames