Skip to main content

Ctrl+K

Safir

User guide
API reference
Change log
Development guide
Rubin docs

GitHub

User guide
API reference
Change log
Development guide
Rubin docs

GitHub

Section Navigation

build_arq_redis_settings

ArqJobError
ArqMode
ArqQueue
JobMetadata
JobNotFound
JobNotQueued
JobResult
JobResultUnavailable
MockArqQueue
RedisArqQueue
WorkerSettings

build_worker

WorkerConfig
WorkerError
WorkerErrorType
WorkerFatalError
WorkerJobInfo
WorkerResult
WorkerTimeoutError
WorkerTransientError
WorkerUsageError

UWS_QUEUE_NAME

run_with_asyncio

AsyncMultiQueue
AsyncMultiQueueError

display_help

create_async_session
create_database_engine
datetime_from_db
datetime_to_db
drop_database
initialize_database
is_database_current
retry_async_transaction
run_migrations_offline
run_migrations_online
stamp_database
stamp_database_async
unstamp_database

AlembicConfigError
CountedPaginatedList
CountedPaginatedQueryRunner
DatabaseInitializationError
DatetimeIdCursor
InvalidCursorError
PaginatedList
PaginatedQueryRunner
PaginationCursor
PaginationLinkData

current_datetime
format_datetime_for_logging
isodatetime
parse_isodatetime
parse_timedelta

ArqDependency

arq_dependency

DatabaseSessionDependency

db_session_dependency

auth_delegated_token_dependency
auth_dependency
auth_logger_dependency

HTTPClientDependency

DEFAULT_HTTP_TIMEOUT
http_client_dependency

LoggerDependency

logger_dependency

EventDependency
EventMaker

client_request_error_handler

ClientRequestError

SignedURLService

GitHubAppClientFactory

GitHubBlobModel
GitHubBranchCommitModel
GitHubBranchModel
GitHubCheckRunAnnotationLevel
GitHubCheckRunConclusion
GitHubCheckRunModel
GitHubCheckRunOutput
GitHubCheckRunPrInfoModel
GitHubCheckRunStatus
GitHubCheckSuiteConclusion
GitHubCheckSuiteId
GitHubCheckSuiteModel
GitHubCheckSuiteStatus
GitHubPullRequestHeadModel
GitHubPullRequestModel
GitHubPullState
GitHubRepoOwnerModel
GitHubRepositoryModel
GitHubUserModel

GitHubAppInstallationEventAction
GitHubAppInstallationEventModel
GitHubAppInstallationEventRepoModel
GitHubAppInstallationModel
GitHubAppInstallationRepositoriesEventAction
GitHubAppInstallationRepositoriesEventModel
GitHubCheckRunEventAction
GitHubCheckRunEventModel
GitHubCheckSuiteEventAction
GitHubCheckSuiteEventModel
GitHubPullRequestEventAction
GitHubPullRequestEventModel
GitHubPushEventModel

AIOKafkaParams
Compatibility
FastStreamBrokerParams
IncompatibleSchemaError
InvalidAvroNameError
InvalidMetadataError
KafkaConnectionSettings
PlaintextSettings
PydanticSchemaManager
SaslMechanism
SaslPlaintextSettings
SaslSslSettings
SchemaInfo
SchemaManagerSettings
SchemaRegistryClientParams
SecurityProtocol
SslSettings
UnknownDeserializeError
UnknownSchemaError

initialize_kubernetes

add_log_severity
configure_alembic_logging
configure_logging
configure_uvicorn_logging

LogLevel
Profile

get_metadata
get_project_url

Metadata

metrics_configuration_factory

BaseAssertionError
BaseMetricsConfiguration
DisabledMetricsConfiguration
DuplicateEventError
EventManager
EventManagerUnintializedError
EventMetadata
EventPayload
EventPublisher
EventsConfiguration
KafkaEventManager
KafkaEventPublisher
KafkaMetricsConfiguration
KafkaTopicError
MockEventManager
MockEventPublisher
MockMetricsConfiguration
NoopEventManager
NoopEventPublisher
NotPublishedConsecutivelyError
NotPublishedError
PublishedCountError
PublishedList
PublishedTooFewError

ANY
NOT_NONE
MetricsConfiguration

ErrorDetail
ErrorLocation
ErrorModel

CaseInsensitiveFormMiddleware
CaseInsensitiveQueryMiddleware

XForwardedMiddleware

normalize_datetime
normalize_isodatetime
to_camel_case
validate_exactly_one_of

CamelCaseModel

DeserializeError
EncryptedPydanticRedisStorage
PydanticRedisStorage

before_send_handler
duration
fingerprint_env_handler
sentry_exception_handler

SentryException
SentryWebException

SlackBaseBlock
SlackBaseField
SlackCodeBlock
SlackCodeField
SlackException
SlackMessage
SlackTextBlock
SlackTextField
SlackWebException

SlackIgnoredException
SlackRouteErrorHandler
SlackWebhookClient

FullKafkaContainer
SchemaRegistryContainer

patch_google_storage

MockBlob
MockBucket
MockStorageClient

patch_kubernetes
strip_none

MockKubernetesApi

parse_log_tuples

capture_events_fixture
sentry_init_fixture

Attachment
Captured
TestTransport

mock_slack_webhook

MockSlackWebhook

spawn_uvicorn

ServerNotListeningError
UvicornProcess

assert_job_summary_equal
patch_wobbly

MockUWSJobRunner
MockWobbly

Job
JobBase
JobCreate
JobError
JobResult
JobUpdateAborted
JobUpdateCompleted
JobUpdateError
JobUpdateExecuting
JobUpdateMetadata
JobUpdateQueued
ParameterError
ParametersModel
SerializedJob
UWSAppSettings
UWSApplication
UWSConfig
UWSError
UWSRoute
UsageError

API reference
AsyncMultiQueueError

AsyncMultiQueueError#

exception safir.asyncio.AsyncMultiQueueError#

Bases: Exception

Invalid sequence of calls when writing to AsyncMultiQueue.

previous

AsyncMultiQueue

next

display_help

On this page

AsyncMultiQueueError

© Copyright 2020-2024 Association of Universities for Research in Astronomy, Inc. (AURA).

Created using Sphinx 8.1.3.

Built with the PyData Sphinx Theme 0.16.1.