PYME.ParallelTasks.ruleserver module

class PYME.ParallelTasks.ruleserver.IntegerIDRule(ruleID, task_template, inputs_by_task=None, max_task_ID=100000, task_timeout=600, rule_timeout=3600)

Bases: PYME.ParallelTasks.ruleserver.Rule

Attributes

advert
expired

Methods

bid(bid) Bid on tasks (and return any that match).
info()
make_range_available(start, end) Make a range of tasks available (to be called once the underlying data is available)
mark_complete(info)
poll_timeouts()
TASK_INFO_DTYPE = dtype([('status', 'u1'), ('nRetries', 'u1'), ('expiry', '<f4'), ('cost', '<f4')])
advert
bid(bid)

Bid on tasks (and return any that match). Note the current implementation is very naive and expects doesn’t check bid cost

Parameters:bid : dictionary containing the following items: ruleID, taskIDs, taskCosts
expired
info()
make_range_available(start, end)

Make a range of tasks available (to be called once the underlying data is available)

mark_complete(info)
poll_timeouts()
class PYME.ParallelTasks.ruleserver.Rule

Bases: object

class PYME.ParallelTasks.ruleserver.RuleServer

Bases: object

Methods

stop()
MAX_ADVERTISEMENTS = 30000
stop()
class PYME.ParallelTasks.ruleserver.ServerThread(port, profile=False)

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()
shutdown()
run()
shutdown()
class PYME.ParallelTasks.ruleserver.WFRuleServer(port)

Bases: PYME.ParallelTasks.webframework.APIHTTPServer, PYME.ParallelTasks.ruleserver.RuleServer

Attributes

timeout  

Methods

stop()
PYME.ParallelTasks.ruleserver.on_SIGHUP(signum, frame)