saturn_engine.worker.services.hooks

Functions

listfield()

Classes

Hooks([options])
HooksLists(hook_failed, items_batched, ...)
ItemsBatch(items, job)
MessagePublished(xmsg, topic, output)
PipelineEventsEmitted(xmsg, events)
ResultsProcessed(xmsg, results)