Package invocations :: Package cu1 :: Module cu1 :: Class Cu1
[hide private]

Class Cu1

source code


Download data from CASU using the module cu1Transfer.

Nested Classes [hide private]
  XferParams
XferParams(scpMainDir, scpThreads, checkTimeFlag, checkMd5Flag, UKLight, forceTransfer, deprecationMode, database, outPrefix, reproMethod, reproVersStr, ffluOnly, onlyHeaderTransfer, isTestRun)

Inherited from wsatools.DbConnect.IngCuSession.IngCuSession: IngCuError

Instance Methods [hide private]
 
__init__(self, curator='rsc', database='WSA', runDate=False, versionStr=False, casuDisk=False, timeCheck=False, numThreads=False, janet=False, deprecation=False, xferList=False, isTrialRun=False, forceXfer=False, reproMode=False, ffluOnly=False, onlyHeader=False, gesOptions=False, comment='A useful comment')
Initialises data members for all database state flags and details for this curation session.
source code
 
_initFromDB(self)
initialize constants from the DB
source code
 
_onRun(self)
Do CU1.
source code
 
_createLock(self)
Create a lock, writing info to sysLog.
source code

Inherited from wsatools.DbConnect.IngCuSession.IngCuSession: __del__, attributesFromArguments, createFileList, createLogFileName, createMonthlyDetSchema, createWorkingDir, getDetTable, getErrorFileName, getMultiframeIDs, getProcessOrder, getProgramIDs, makeSysCmd, removeWorkingDir, run, runSysCmd, setupDetectionTable, testForProgs, translateProgID, writeErrorFiles, writeIngestList

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

Static Methods [hide private]

Inherited from wsatools.DbConnect.IngCuSession.IngCuSession: createFilePrefix

Class Variables [hide private]
  DLStatus = 1
  dateSet = set([])

Inherited from wsatools.DbConnect.IngCuSession.IngCuSession: beginDateDef, endDateDef, keepWorkDir, reqWorkDir, sysc

Instance Variables [hide private]
Properties [hide private]

Inherited from object: __class__

Method Details [hide private]

__init__(self, curator='rsc', database='WSA', runDate=False, versionStr=False, casuDisk=False, timeCheck=False, numThreads=False, janet=False, deprecation=False, xferList=False, isTrialRun=False, forceXfer=False, reproMode=False, ffluOnly=False, onlyHeader=False, gesOptions=False, comment='A useful comment')
(Constructor)

source code 

Initialises data members for all database state flags and details for this curation session. Writes a database lock and opens a connection. Also initiates a Programme table object.

Parameters:
  • casuDisk (str) - Disk at CASU where the data is stored.
  • comment (str) - Descriptive comment as to why curation task is being performed.
  • curator (str) - Name of curator.
  • deprecation (str) - Modus for deprecating files.
  • ffluOnly (bool) - Don't transfer but update FlatfileLookup table.
  • forceXfer (bool) - Force the data transfer.
  • gesOptions (str) - GES instrument and type.
  • isTrialRun (bool) - If True, do not perform database modifications.
  • janet (bool) - Use JANET instead of UKLight.
  • numThreads (int) - Number of scp transfer threads.
  • onlyHeader (bool) - Only transfer FITS headers.
  • reproMode (str) - Mode for reprocessed data: otm (one-to-many dirs) or s::suffix (CASU datedir suffix).
  • runDate (list(int)) - Dates to process, eg. [20050101].
  • timeCheck (bool) - Determines if existing files should be checked for their timestamp against the same file at CASU;
  • versionStr (str) - Version number of the data.
  • xferList (list) - List containing files to be downloaded.
Overrides: object.__init__

_onRun(self)

source code 

Do CU1.

Overrides: wsatools.DbConnect.IngCuSession.IngCuSession._onRun

_createLock(self)

source code 

Create a lock, writing info to sysLog. If lock exists, abort.