Class DirectOutputHandler

x.__init__(...) initializes x; see help(type(x)) for signature

Overrides: object.__init__

(inherited documentation)

Called to indicate that a worker has data to read from a specific node (or key).

:param worker: :class:`.Worker` object

Available worker attributes:

* :attr:`.Worker.current_node` - node (or key) * :attr:`.Worker.current_msg` - read message

Overrides: Event.EventHandler.ev_read

(inherited documentation)

Called to indicate that a worker has error to read on stderr from a specific node (or key).

:param worker: :class:`.Worker` object

Available worker attributes:

* :attr:`.Worker.current_node` - node (or key) * :attr:`.Worker.current_errmsg` - read error message

Overrides: Event.EventHandler.ev_error

(inherited documentation)

Called to indicate that a worker command for a specific node (or key) has just finished. Called for each node.

:param worker: :class:`.Worker` object

Available worker attributes:

* :attr:`.Worker.current_node` - node (or key) * :attr:`.Worker.current_rc` - command return code

Overrides: Event.EventHandler.ev_hup

(inherited documentation)

Called to indicate that a worker has timed out (worker timeout only).

:param worker: :class:`.Worker` object

Overrides: Event.EventHandler.ev_timeout

(inherited documentation)

Called to indicate that a worker has just finished (it may already have failed on timeout).

:param worker: :class:`.Worker` object

Overrides: Event.EventHandler.ev_close

(inherited documentation)