Package invocations :: Package cu1 :: Module cu1 :: Class ThreadDL

Class ThreadDL

source code

Instance Methods

[hide private]

xferThreads(self, params, procDates, resultQueue)
Run the transfers.

source code

dict

run(self, dateList, xferParams)
Thread the downloads.

source code

dict

finaliseTransfer(self, resultDict)
Process the results.

source code

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

Class Variables

[hide private]

numprocessors = 2

DLStatus = 1

Properties

[hide private]

Inherited from object: __class__

Method Details

[hide private]

xferThreads(self, params, procDates, resultQueue)

source code

Run the transfers.

Parameters:

params (namedtuple) - Parameters for CASUTransfer class.
procDates (list) - The dates to transfer in parallel.
resultQueue (Queue object) - The results queue.

run(self, dateList, xferParams)

source code

Thread the downloads.

Parameters:

dateList (list) - The dates to transfer in parallel.
xferParams (namedtuple) - Parameters for CASUTransfer class.

Returns: dict

Dictionary containing metadata of the daily transfers.

finaliseTransfer(self, resultDict)

source code

Process the results.

Returns: dict: Dictionary containing metadata of the daily transfers.