primus.command_worker.adapters package

Provider-specific implementations of portable command-worker ports.

Import adapters from their concrete module so an installation only needs the dependencies for the providers it enables.

Submodules

• primus.command_worker.adapters.celery_delivery module
  • OwnerFactory
    • OwnerFactory.__init__()
  • register_portable_command_task()
• primus.command_worker.adapters.dynamodb_lifecycle module
  • DynamoDBLifecycleStore
    • DynamoDBLifecycleStore.__init__()
    • DynamoDBLifecycleStore.claim()
    • DynamoDBLifecycleStore.complete()
    • DynamoDBLifecycleStore.fail()
    • DynamoDBLifecycleStore.finalize_cancel()
    • DynamoDBLifecycleStore.renew()
    • DynamoDBLifecycleStore.report_progress()
• primus.command_worker.adapters.ecs_task_protection module
  • EcsAgentTaskScaleInProtection
    • EcsAgentTaskScaleInProtection.__init__()
    • EcsAgentTaskScaleInProtection.clear()
    • EcsAgentTaskScaleInProtection.enable()
• primus.command_worker.adapters.task_store module
  • GraphQLTaskStoreGateway
    • GraphQLTaskStoreGateway.__init__()
    • GraphQLTaskStoreGateway.announce_task()
    • GraphQLTaskStoreGateway.claim_task()
    • GraphQLTaskStoreGateway.complete_task()
    • GraphQLTaskStoreGateway.fail_task()
    • GraphQLTaskStoreGateway.finalize_task_cancel()
    • GraphQLTaskStoreGateway.get_command()
    • GraphQLTaskStoreGateway.get_task()
    • GraphQLTaskStoreGateway.progress_task()
    • GraphQLTaskStoreGateway.renew_task()
    • GraphQLTaskStoreGateway.request_task_cancel()
  • TaskBackedCommandStore
    • TaskBackedCommandStore.__init__()
    • TaskBackedCommandStore.announce()
    • TaskBackedCommandStore.claim()
    • TaskBackedCommandStore.complete()
    • TaskBackedCommandStore.fail()
    • TaskBackedCommandStore.finalize_cancel()
    • TaskBackedCommandStore.get()
    • TaskBackedCommandStore.renew()
    • TaskBackedCommandStore.report_progress()
    • TaskBackedCommandStore.request_cancel()
  • TaskStoreGateway
    • TaskStoreGateway.__init__()
    • TaskStoreGateway.announce_task()
    • TaskStoreGateway.claim_task()
    • TaskStoreGateway.complete_task()
    • TaskStoreGateway.fail_task()
    • TaskStoreGateway.finalize_task_cancel()
    • TaskStoreGateway.get_command()
    • TaskStoreGateway.get_task()
    • TaskStoreGateway.progress_task()
    • TaskStoreGateway.renew_task()
    • TaskStoreGateway.request_task_cancel()