MCPcopy Create free account
hub / github.com/StackStorm/st2 / dispatch

Method dispatch

st2common/st2common/util/greenpooldispatch.py:64–66  ·  view source on GitHub ↗
(self, handler, *args)

Source from the content-addressed store, hash-verified

62 return self._name or id(self)
63
64 def dispatch(self, handler, *args):
65 self._work_buffer.put((handler, args), block=True, timeout=1)
66 self._flush_now()
67
68 def shutdown(self):
69 self._dispatch_monitor_thread.kill()

Callers 2

test_dispatch_simpleMethod · 0.95
test_dispatch_starvedMethod · 0.95

Calls 2

_flush_nowMethod · 0.95
putMethod · 0.45

Tested by 2

test_dispatch_simpleMethod · 0.76
test_dispatch_starvedMethod · 0.76