Skip to main content
Ctrl+K

Safir

  • User guide
  • API reference
  • Change log
  • Development guide
  • GitHub
  • User guide
  • API reference
  • Change log
  • Development guide
  • 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
  • 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
  • PaginationLinkData
  • AIOKafkaParams
  • Compatibility
  • FastStreamBrokerParams
  • FastStreamErrorHandler
  • 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
  • EventManagerUninitializedError
  • EventManagerUsageError
  • EventMetadata
  • EventPayload
  • EventPublisher
  • EventsConfiguration
  • FailedEventPublisher
  • KafkaEventManager
  • KafkaEventPublisher
  • KafkaMetricsConfiguration
  • KafkaTopicError
  • MockEventManager
  • MockEventPublisher
  • MockMetricsConfiguration
  • NoopEventManager
  • NoopEventPublisher
  • NotPublishedConsecutivelyError
  • NotPublishedError
  • PublishedCountError
  • PublishedList
  • PublishedTooFewError
  • UnsupportedAvroSchemaError
  • ANY
  • NOT_NONE
  • MetricsConfiguration
  • initialize_arq_metrics
  • make_on_job_start
  • publish_queue_stats
  • ArqEvents
  • ArqMetricsError
  • ArqQueueJobEvent
  • ArqQueueStatsEvent
  • ARQ_EVENTS_CONTEXT_KEY
  • ErrorDetail
  • ErrorLocation
  • ErrorModel
  • CaseInsensitiveFormMiddleware
  • CaseInsensitiveQueryMiddleware
  • XForwardedMiddleware
  • normalize_datetime
  • normalize_isodatetime
  • to_camel_case
  • validate_exactly_one_of
  • CamelCaseModel
  • EnvAsyncPostgresDsn
  • EnvRedisDsn
  • HumanTimedelta
  • IvoaIsoDatetime
  • SecondsTimedelta
  • UtcDatetime
  • DeserializeError
  • EncryptedPydanticRedisStorage
  • PydanticRedisStorage
  • before_send_handler
  • duration
  • fingerprint_env_handler
  • initialize_sentry
  • report_exception
  • sentry_exception_handler
  • should_enable_sentry
  • SentryConfig
  • SentryEventInfo
  • SlackBaseBlock
  • SlackBaseField
  • SlackCodeBlock
  • SlackCodeField
  • SlackException
  • SlackMessage
  • SlackTextBlock
  • SlackTextField
  • SlackWebException
  • SlackIgnoredException
  • SlackRouteErrorHandler
  • SlackWebhookClient
  • FullKafkaContainer
  • SchemaRegistryContainer
  • Data
  • 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
  • PublishedTooFewError

PublishedTooFewError#

exception safir.metrics.PublishedTooFewError(expected, actual, actual_models)#

Bases: BaseAssertionError, Generic

Expected more events than have actually been published.

Parameters:
  • expected (list[dict[str, Any]])

  • actual (list[dict[str, Any]])

  • actual_models (list[TypeVar(P, bound= EventPayload)])

errormsg()#

Return a string to be added to the exception message.

Return type:

str

This page was last modified on 2026-02-26.

https://safir.lsst.io/api/safir.metrics.PublishedTooFewError.html

previous

PublishedList

next

UnsupportedAvroSchemaError

This page was last modified on 2026-02-26.

On this page
  • PublishedTooFewError
    • PublishedTooFewError.errormsg()

Rubin Observatory

  • For scientists
  • News

Documentation

data.lsst.cloud

Community forum

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

The U.S. National Science Foundation (NSF) and the U.S. Department of Energy (DOE) Office of Science will support Rubin Observatory in its operations phase to carry out the Legacy Survey of Space and Time. They will also provide support for scientific research with the data. During operations, NSF funding is managed by the Association of Universities for Research in Astronomy (AURA) under a cooperative agreement with NSF, and DOE funding is managed by SLAC National Accelerator Laboratory (SLAC), under contract by DOE. Rubin Observatory is operated by NSF NOIRLab and SLAC.

NSF is an independent federal agency created by Congress in 1950 to promote the progress of science. NSF supports basic research and people to create knowledge that transforms the future.

The DOE Office of Science is the single largest supporter of basic research in the physical sciences in the United States and is working to address some of the most pressing challenges of our time.

Logos of the Vera C. Rubin Observatory, NSF, US DOE, NOIRLab, AURA, and SLAC.