MCPcopy Create free account
hub / github.com/apache/storm / emitDirect

Function emitDirect

storm-multilang/python/src/main/resources/resources/storm.py:106–108  ·  view source on GitHub ↗
(task, *args, **kwargs)

Source from the content-addressed store, hash-verified

104
105
106def emitDirect(task, *args, **kwargs):
107 kwargs["directTask"] = task
108 __emit(*args, **kwargs)
109
110
111def __emit(*args, **kwargs):

Callers

nothing calls this directly

Calls 1

__emitFunction · 0.85

Tested by

no test coverage detected