spreadflow_core.scheduler module

class spreadflow_core.scheduler.AttachEvent(scheduler, reactor)

Bases: tuple

__getnewargs__()

Return self as a plain tuple. Used by copy and pickle.

__getstate__()

Exclude the OrderedDict from pickling

__repr__()

Return a nicely formatted representation string

reactor

Alias for field number 1

scheduler

Alias for field number 0

class spreadflow_core.scheduler.DetachEvent(scheduler)

Bases: tuple

__getnewargs__()

Return self as a plain tuple. Used by copy and pickle.

__getstate__()

Exclude the OrderedDict from pickling

__repr__()

Return a nicely formatted representation string

scheduler

Alias for field number 0

class spreadflow_core.scheduler.Entry(deferred, job)

Bases: tuple

__getnewargs__()

Return self as a plain tuple. Used by copy and pickle.

__getstate__()

Exclude the OrderedDict from pickling

__repr__()

Return a nicely formatted representation string

deferred

Alias for field number 0

job

Alias for field number 1

class spreadflow_core.scheduler.Job(port, item, send, origin=None, handler=None)

Bases: object

class spreadflow_core.scheduler.JobEvent(scheduler, job, completed)

Bases: tuple

__getnewargs__()

Return self as a plain tuple. Used by copy and pickle.

__getstate__()

Exclude the OrderedDict from pickling

__repr__()

Return a nicely formatted representation string

completed

Alias for field number 2

job

Alias for field number 1

scheduler

Alias for field number 0

class spreadflow_core.scheduler.Scheduler(flowmap, eventdispatcher, cooperate=None)

Bases: object

join(*args, **kwargs)

log

A L{Logger} emits log messages to an observer. You should instantiate it as a class or module attribute, as documented in L{this module’s documentation <twisted.logger>}.

pending

run(*args, **kwargs)

send(item, port_out)

stop(reason)