PYME.ParallelTasks.taskServerZC module

class PYME.ParallelTasks.taskServerZC.TaskQueueSet(process_queues_in_order=False)

Bases: Pyro.core.ObjBase

Methods

addQueueEvents(queueName, *args) Set data ascociated with queue
checkTimeouts()
createQueue(queueType, queueName, *args, ...)
getCompletedTask([queueName])
getNumTasksProcessed([workerName])
getNumberOpenTasks([queueName, exact])
getNumberTasksCompleted([queueName])
getNumberTasksInProgress([queueName])
getQueueData(queueName, *args) Get data ascociated with queue - for cases when you might not want to send data with task every time e.g.
getQueueMetaData(queueName, *args) Get meta-data ascociated with queue
getQueueMetaDataKeys(queueName, *args) Get meta-data keys ascociated with queue
getQueueNames()
getTask([workerName, workerVersion]) get task from front of list, blocks
getTasks([workerName, workerVersion]) get task from front of list, non-blocking
getWorkerFPS(workerName)
getWorkerNames()
isAlive()
kill()
logQueueEvent(queueName, *args) Report an event ot a queue
postTask(task[, queueName]) Post a task to the queue of the given name.
postTasks(tasks[, queueName])
purge([queueName])
releaseTasks(queueName, *args) Release held tasks
removeQueue(queueName)
returnCompletedTask(taskResult[, ...])
returnCompletedTasks(taskResult[, ...])
setPopFcn(queueName, fcn)
setQueueData(queueName, *args) Set data ascociated with queue
setQueueMetaData(queueName, *args) Set meta-data ascociated with queue
setQueueMetaDataEntries(queueName, *args) Set meta-data ascociated with queue
addQueueEvents(queueName, *args)

Set data ascociated with queue

checkTimeouts()
createQueue(queueType, queueName, *args, **kwargs)
getCompletedTask(queueName='Default')
getNumTasksProcessed(workerName=None)
getNumberOpenTasks(queueName=None, exact=True)
getNumberTasksCompleted(queueName=None)
getNumberTasksInProgress(queueName=None)
getQueueData(queueName, *args)

Get data ascociated with queue - for cases when you might not want to send data with task every time e.g. to allow client side buffering of image data

getQueueMetaData(queueName, *args)

Get meta-data ascociated with queue

getQueueMetaDataKeys(queueName, *args)

Get meta-data keys ascociated with queue

getQueueNames()
getTask(workerName='Unspecified', workerVersion=None)

get task from front of list, blocks

getTasks(workerName='Unspecified', workerVersion=None)

get task from front of list, non-blocking

getWorkerFPS(workerName)
getWorkerNames()
isAlive()
kill()
logQueueEvent(queueName, *args)

Report an event ot a queue

postTask(task, queueName='Default')

Post a task to the queue of the given name. A task represents a chunk of work to be done. Parameters ———- task queueName

postTasks(tasks, queueName='Default')
purge(queueName='Default')
releaseTasks(queueName, *args)

Release held tasks

removeQueue(queueName)
returnCompletedTask(taskResult, workerName='Unspecified', timeTaken=None)
returnCompletedTasks(taskResult, workerName='Unspecified', timeTaken=None)
setPopFcn(queueName, fcn)
setQueueData(queueName, *args)

Set data ascociated with queue

setQueueMetaData(queueName, *args)

Set meta-data ascociated with queue

setQueueMetaDataEntries(queueName, *args)

Set meta-data ascociated with queue

class PYME.ParallelTasks.taskServerZC.TaskWatcher(tQueue)

Bases: threading.Thread

Attributes

daemon A boolean value indicating whether this thread is a daemon thread (True) or not (False).
ident Thread identifier of this thread or None if it has not been started.
name A string used for identification purposes only.

Methods

run()
run()
PYME.ParallelTasks.taskServerZC.main()