Hide navigation sidebar

Hide table of contents sidebar

Toggle site navigation sidebar

Saturn documentation

Toggle table of contents sidebar

Saturn documentation

Getting Started
Toggle navigation of Getting Started
How-to guides
Toggle navigation of How-to guides
- Run Sub Jobs
- Gracefully cancel job
Key topics
Toggle navigation of Key topics
- General Architecture
- Concurrency
References
Toggle navigation of References
- saturn_engine.core
  Toggle navigation of saturn_engine.core
- saturn_engine.worker
  Toggle navigation of saturn_engine.worker
  - saturn_engine.worker.broker
  - saturn_engine.worker.context
  - saturn_engine.worker.error_handling
  - saturn_engine.worker.executors
    Toggle navigation of saturn_engine.worker.executors
    - saturn_engine.worker.executors.arq
      Toggle navigation of saturn_engine.worker.executors.arq
      - saturn_engine.worker.executors.arq.executor
      - saturn_engine.worker.executors.arq.worker
    - saturn_engine.worker.executors.bootstrap
    - saturn_engine.worker.executors.executable
    - saturn_engine.worker.executors.manager
    - saturn_engine.worker.executors.parkers
    - saturn_engine.worker.executors.process
    - saturn_engine.worker.executors.queue
    - saturn_engine.worker.executors.scheduler
  - saturn_engine.worker.inventories
    Toggle navigation of saturn_engine.worker.inventories
  - saturn_engine.worker.inventory
  - saturn_engine.worker.job
  - saturn_engine.worker.pipeline_message
  - saturn_engine.worker.resources
    Toggle navigation of saturn_engine.worker.resources
    - saturn_engine.worker.resources.manager
    - saturn_engine.worker.resources.provider
  - saturn_engine.worker.runner
  - saturn_engine.worker.services
    Toggle navigation of saturn_engine.worker.services
    - saturn_engine.worker.services.api_client
    - saturn_engine.worker.services.databases
    - saturn_engine.worker.services.extras
      Toggle navigation of saturn_engine.worker.services.extras
      - saturn_engine.worker.services.extras.sentry
    - saturn_engine.worker.services.hooks
    - saturn_engine.worker.services.http_client
    - saturn_engine.worker.services.job_state
      Toggle navigation of saturn_engine.worker.services.job_state
      - saturn_engine.worker.services.job_state.service
      - saturn_engine.worker.services.job_state.store
    - saturn_engine.worker.services.loggers
      Toggle navigation of saturn_engine.worker.services.loggers
      - saturn_engine.worker.services.loggers.console_logging
      - saturn_engine.worker.services.loggers.logger
    - saturn_engine.worker.services.manager
    - saturn_engine.worker.services.metrics
    - saturn_engine.worker.services.rabbitmq
    - saturn_engine.worker.services.remote_pdb
    - saturn_engine.worker.services.tasks_runner
    - saturn_engine.worker.services.tracing
      Toggle navigation of saturn_engine.worker.services.tracing
    - saturn_engine.worker.services.usage_metrics
  - saturn_engine.worker.topic
  - saturn_engine.worker.topics
    Toggle navigation of saturn_engine.worker.topics
  - saturn_engine.worker.work_factory
  - saturn_engine.worker.work_manager
  - saturn_engine.worker.worker_manager

Toggle table of contents sidebar

saturn_engine.worker.topics.batching#

Classes

`BatchMessage`(batch)
`BatchingTopic`(options, services, **kwargs)

saturn_engine.worker.topics.delayed

saturn_engine.worker.topics

Copyright © 2023, Flare

Made with Sphinx and @pradyunsg's Furo