saturn_engine.worker.topic#

Classes

BlockingTopic([max_concurrency, sleep_time])

Topic(*args, options, **kwargs)

Exceptions

TopicClosedError