saturn_engine.core.api

Classes

ComponentDefinition(name, type, options, ...)
ErrorHandler([set_handled, republish])
FetchCursorsStatesInput(cursors)
FetchCursorsStatesResponse(cursors)
InventoriesResponse(items)
ItemResponse(data)
JobCompletion(completed_at[, error])
JobDefinition(name, template, minimal_interval)
JobDefinitionsResponse(items)
JobInput([cursor, completed_at, error])
JobItem(name, started_at[, completed_at, ...])
JobResponse(data)
JobState(cursor, cursors_states, dict] =, ...)
JobsResponse(items)
JobsStartResponse(name)
JobsStates(jobs, ...)
JobsStatesSyncInput(state)
JobsStatesSyncResponse()
JobsSyncResponse()
ListResponse(items)
LockInput(worker_id[, selector, executors])
LockResponse(items, resources, ...)
QueueItem(name, pipeline, output, ...)
QueueItemState(cursor, started_at)
QueueItemWithState(name, pipeline, output, ...)
RepublishOptions(channel, max_retry)
ResourceItem(name, type, data[, ...])
ResourceRateLimitItem(rate_limits[, strategy])
ResourcesProviderItem(name, type, ...)
StartJobInput([name, job_definition_name])
TopicsResponse(items)
UpdateResponse()