Index

_

__call__() (safir.dependencies.arq.ArqDependency method) (safir.dependencies.db_session.DatabaseSessionDependency method) (safir.dependencies.http_client.HTTPClientDependency method) (safir.dependencies.logger.LoggerDependency method) (safir.dependencies.metrics.EventDependency method) (safir.middleware.ivoa.CaseInsensitiveFormMiddleware method) (safir.middleware.ivoa.CaseInsensitiveQueryMiddleware method) (safir.middleware.x_forwarded.XForwardedMiddleware method)

A

abort_job() (safir.arq.ArqQueue method) (safir.arq.MockArqQueue method) (safir.arq.RedisArqQueue method) aclose() (safir.dependencies.db_session.DatabaseSessionDependency method) (safir.dependencies.http_client.HTTPClientDependency method) (safir.metrics.EventManager method) (safir.metrics.KafkaEventManager method) action (safir.github.webhooks.GitHubAppInstallationEventModel attribute) (safir.github.webhooks.GitHubAppInstallationRepositoriesEventModel attribute) (safir.github.webhooks.GitHubCheckRunEventModel attribute) (safir.github.webhooks.GitHubCheckSuiteEventModel attribute) (safir.github.webhooks.GitHubPullRequestEventModel attribute) action_required (safir.github.models.GitHubCheckRunConclusion attribute) (safir.github.models.GitHubCheckSuiteConclusion attribute) add_log_severity() (in module safir.logging) added (safir.github.webhooks.GitHubAppInstallationRepositoriesEventAction attribute) after (safir.github.webhooks.GitHubPushEventModel attribute) AIOKafkaParams (class in safir.kafka) aiter_from() (safir.asyncio.AsyncMultiQueue method) AlembicConfigError allow_abort_jobs (safir.arq.WorkerSettings attribute) ANY (in module safir.metrics) application (safir.metrics.BaseMetricsConfiguration attribute) (safir.metrics.EventMetadata attribute) apply_cursor() (safir.database.DatetimeIdCursor method) (safir.database.PaginationCursor method)

apply_order() (safir.database.DatetimeIdCursor class method) (safir.database.PaginationCursor class method) args (safir.arq.JobMetadata attribute) (safir.arq.JobResult attribute) arq_dependency (in module safir.dependencies.arq) arq_mode (safir.uws.UWSAppSettings attribute) arq_queue_password (safir.uws.UWSAppSettings attribute) arq_queue_url (safir.uws.UWSAppSettings attribute) arq_redis_settings (safir.arq.uws.WorkerConfig attribute) (safir.uws.UWSAppSettings property) ArqDependency (class in safir.dependencies.arq) ArqJobError ArqMode (class in safir.arq) ArqQueue (class in safir.arq) assert_job_summary_equal() (in module safir.testing.uws) assert_published() (safir.metrics.PublishedList method) assert_published_all() (safir.metrics.PublishedList method) assigned (safir.github.webhooks.GitHubPullRequestEventAction attribute) AsyncMultiQueue (class in safir.asyncio) AsyncMultiQueueError attachments (safir.slack.blockkit.SlackMessage attribute) auth_delegated_token_dependency() (in module safir.dependencies.gafaelfawr) auth_dependency() (in module safir.dependencies.gafaelfawr) auth_logger_dependency() (in module safir.dependencies.gafaelfawr) auto_merge_disabled (safir.github.webhooks.GitHubPullRequestEventAction attribute) auto_merge_enabled (safir.github.webhooks.GitHubPullRequestEventAction attribute) avatar_url (safir.github.models.GitHubUserModel attribute)

B

BACKWARD (safir.kafka.Compatibility attribute) BACKWARD_TRANSITIVE (safir.kafka.Compatibility attribute) BaseAssertionError before (safir.github.webhooks.GitHubPushEventModel attribute) blob() (safir.testing.gcs.MockBucket method) blobs_url (safir.github.models.GitHubRepositoryModel attribute) blocks (safir.slack.blockkit.SlackMessage attribute) body (safir.models.ErrorLocation attribute) bootstrap_servers (safir.kafka.KafkaConnectionSettings attribute) (safir.kafka.PlaintextSettings attribute) (safir.kafka.SaslPlaintextSettings attribute) (safir.kafka.SaslSslSettings attribute) (safir.kafka.SslSettings attribute)

branches_url (safir.github.models.GitHubRepositoryModel attribute) bucket() (safir.testing.gcs.MockStorageClient method) build_arq_redis_settings() (in module safir.arq) build_publisher_for_model() (safir.metrics.EventManager method) (safir.metrics.KafkaEventManager method) (safir.metrics.MockEventManager method) (safir.metrics.NoopEventManager method) build_uws_config() (safir.uws.UWSAppSettings method) build_worker() (in module safir.arq.uws) (safir.uws.UWSApplication method)

C

cancelled (safir.github.models.GitHubCheckRunConclusion attribute) (safir.github.models.GitHubCheckSuiteConclusion attribute) CaseInsensitiveFormMiddleware (class in safir.middleware.ivoa) CaseInsensitiveQueryMiddleware (class in safir.middleware.ivoa) cause_type (safir.arq.uws.WorkerError attribute) check_run (safir.github.webhooks.GitHubCheckRunEventModel attribute) check_suite (safir.github.models.GitHubCheckRunModel attribute) (safir.github.webhooks.GitHubCheckSuiteEventModel attribute) clear() (safir.asyncio.AsyncMultiQueue method) client_cert_path (safir.kafka.KafkaConnectionSettings attribute) (safir.kafka.SslSettings attribute) client_key_path (safir.kafka.KafkaConnectionSettings attribute) (safir.kafka.SslSettings attribute) client_request_error_handler() (in module safir.fastapi) ClientRequestError close() (safir.asyncio.AsyncMultiQueue method) closed (safir.github.models.GitHubPullState attribute) (safir.github.webhooks.GitHubPullRequestEventAction attribute) cluster_ca_path (safir.kafka.KafkaConnectionSettings attribute) (safir.kafka.SaslSslSettings attribute) (safir.kafka.SslSettings attribute) code (safir.slack.blockkit.SlackCodeBlock attribute) (safir.slack.blockkit.SlackCodeField attribute) (safir.uws.JobError attribute) commit (safir.github.models.GitHubBranchModel attribute) Compatibility (class in safir.kafka) completed (safir.github.models.GitHubCheckRunStatus attribute) (safir.github.models.GitHubCheckSuiteStatus attribute) (safir.github.webhooks.GitHubCheckRunEventAction attribute) (safir.github.webhooks.GitHubCheckSuiteEventAction attribute) conclusion (safir.github.models.GitHubCheckRunModel attribute) (safir.github.models.GitHubCheckSuiteModel attribute) configure_alembic_logging() (in module safir.logging)

configure_logging() (in module safir.logging) configure_uvicorn_logging() (in module safir.logging) construct_event() (safir.metrics.EventPublisher method) content (safir.github.models.GitHubBlobModel attribute) contents_url (safir.github.models.GitHubRepositoryModel attribute) converted_to_draft (safir.github.webhooks.GitHubPullRequestEventAction attribute) CountedPaginatedList (class in safir.database) CountedPaginatedQueryRunner (class in safir.database) create_anonymous_client() (safir.github.GitHubAppClientFactory method) create_async_session() (in module safir.database) create_database_engine() (in module safir.database) create_installation_client() (safir.github.GitHubAppClientFactory method) create_installation_client_for_repo() (safir.github.GitHubAppClientFactory method) create_job() (safir.testing.uws.MockWobbly method) create_namespace() (safir.testing.kubernetes.MockKubernetesApi method) create_namespaced_config_map() (safir.testing.kubernetes.MockKubernetesApi method) create_namespaced_custom_object() (safir.testing.kubernetes.MockKubernetesApi method) create_namespaced_event() (safir.testing.kubernetes.MockKubernetesApi method) create_namespaced_ingress() (safir.testing.kubernetes.MockKubernetesApi method) create_namespaced_job() (safir.testing.kubernetes.MockKubernetesApi method) create_namespaced_network_policy() (safir.testing.kubernetes.MockKubernetesApi method) create_namespaced_persistent_volume_claim() (safir.testing.kubernetes.MockKubernetesApi method) create_namespaced_pod() (safir.testing.kubernetes.MockKubernetesApi method) create_namespaced_resource_quota() (safir.testing.kubernetes.MockKubernetesApi method) create_namespaced_secret() (safir.testing.kubernetes.MockKubernetesApi method) create_namespaced_service() (safir.testing.kubernetes.MockKubernetesApi method) create_publisher() (safir.metrics.EventManager method) created (safir.github.webhooks.GitHubAppInstallationEventAction attribute) (safir.github.webhooks.GitHubCheckRunEventAction attribute) creation_time (safir.uws.SerializedJob attribute) CRITICAL (safir.logging.LogLevel attribute) cron_jobs (safir.arq.WorkerSettings attribute) current_datetime() (in module safir.datetime)

D

DatabaseInitializationError DatabaseSessionDependency (class in safir.dependencies.db_session) datetime_from_db() (in module safir.database) datetime_to_db() (in module safir.database) DatetimeIdCursor (class in safir.database) db_session_dependency (in module safir.dependencies.db_session) DEBUG (safir.logging.LogLevel attribute) decode() (safir.github.models.GitHubBlobModel method) default_branch (safir.github.models.GitHubRepositoryModel attribute) DEFAULT_HTTP_TIMEOUT (in module safir.dependencies.http_client) default_queue_name (safir.arq.ArqQueue attribute) delete() (safir.redis.EncryptedPydanticRedisStorage method) (safir.redis.PydanticRedisStorage method) delete_all() (safir.redis.EncryptedPydanticRedisStorage method) (safir.redis.PydanticRedisStorage method) delete_job() (safir.testing.uws.MockWobbly method) delete_namespace() (safir.testing.kubernetes.MockKubernetesApi method) delete_namespaced_config_map() (safir.testing.kubernetes.MockKubernetesApi method) delete_namespaced_custom_object() (safir.testing.kubernetes.MockKubernetesApi method) delete_namespaced_ingress() (safir.testing.kubernetes.MockKubernetesApi method) delete_namespaced_job() (safir.testing.kubernetes.MockKubernetesApi method)

delete_namespaced_persistent_volume_claim() (safir.testing.kubernetes.MockKubernetesApi method) delete_namespaced_pod() (safir.testing.kubernetes.MockKubernetesApi method) delete_namespaced_service() (safir.testing.kubernetes.MockKubernetesApi method) deleted (safir.github.webhooks.GitHubAppInstallationEventAction attribute) demilestoned (safir.github.webhooks.GitHubPullRequestEventAction attribute) dequeued (safir.github.webhooks.GitHubPullRequestEventAction attribute) description (safir.metadata.Metadata attribute) (safir.uws.UWSRoute attribute) DeserializeError destruction_time (safir.uws.JobBase attribute) (safir.uws.JobCreate attribute) (safir.uws.JobUpdateMetadata attribute) detail (safir.arq.uws.WorkerError attribute) (safir.models.ErrorModel attribute) (safir.uws.JobError attribute) development (safir.logging.Profile attribute) display_help() (in module safir.click) documentation_url (safir.metadata.Metadata attribute) draft (safir.github.models.GitHubPullRequestModel attribute) drop_database() (in module safir.database) DuplicateEventError

E

E (in module safir.dependencies.metrics) edited (safir.github.webhooks.GitHubPullRequestEventAction attribute) enabled (safir.metrics.DisabledMetricsConfiguration attribute) (safir.metrics.KafkaMetricsConfiguration attribute) (safir.metrics.MockMetricsConfiguration attribute) encoding (safir.github.models.GitHubBlobModel attribute) EncryptedPydanticRedisStorage (class in safir.redis) end_time (safir.uws.SerializedJob attribute) enqueue() (safir.arq.ArqQueue method) (safir.arq.MockArqQueue method) (safir.arq.RedisArqQueue method) enqueue_time (safir.arq.JobMetadata attribute) (safir.arq.JobResult attribute) ERROR (safir.logging.LogLevel attribute) error_callback (safir.testing.kubernetes.MockKubernetesApi attribute)

error_type (safir.arq.uws.WorkerError attribute) ErrorLocation (class in safir.models) errors (safir.uws.JobUpdateError attribute) (safir.uws.SerializedJob attribute) EventDependency (class in safir.dependencies.metrics) EventMaker (class in safir.dependencies.metrics) EventManager (class in safir.metrics) EventManagerUnintializedError EventPublisher (class in safir.metrics) events (safir.dependencies.metrics.EventDependency attribute) (safir.metrics.BaseMetricsConfiguration attribute) execution_duration (safir.uws.JobBase attribute) (safir.uws.JobCreate attribute) (safir.uws.JobUpdateMetadata attribute) external_id (safir.github.models.GitHubCheckRunModel attribute)

F

failed_at (safir.slack.blockkit.SlackException attribute) failure (safir.github.models.GitHubCheckRunAnnotationLevel attribute) (safir.github.models.GitHubCheckRunConclusion attribute) (safir.github.models.GitHubCheckSuiteConclusion attribute) FastStreamBrokerParams (class in safir.kafka) FATAL (safir.arq.uws.WorkerErrorType attribute) field_path (safir.fastapi.ClientRequestError attribute) fields (safir.slack.blockkit.SlackMessage attribute) finish_time (safir.arq.JobResult attribute) finished (safir.asyncio.AsyncMultiQueue attribute) first_url() (safir.database.PaginatedList method) format_datetime_for_logging() (in module safir.datetime) FORWARD (safir.kafka.Compatibility attribute)

FORWARD_TRANSITIVE (safir.kafka.Compatibility attribute) from_entry() (safir.database.PaginationCursor class method) from_header() (safir.database.PaginationLinkData class method) from_job() (safir.arq.JobMetadata class method) (safir.arq.JobResult class method) from_serialized_job() (safir.uws.Job class method) from_str() (safir.database.DatetimeIdCursor class method) (safir.database.PaginationCursor class method) from_worker_result() (safir.uws.JobResult class method) FULL (safir.kafka.Compatibility attribute) full_name (safir.github.models.GitHubRepositoryModel attribute) (safir.github.webhooks.GitHubAppInstallationEventRepoModel attribute) FULL_TRANSITIVE (safir.kafka.Compatibility attribute)

G

generate_signed_url() (safir.testing.gcs.MockBlob method) get() (safir.redis.EncryptedPydanticRedisStorage method) (safir.redis.PydanticRedisStorage method) get_all_objects_for_test() (safir.testing.kubernetes.MockKubernetesApi method) get_app_jwt() (safir.github.GitHubAppClientFactory method) get_job() (safir.testing.uws.MockWobbly method) get_job_metadata() (safir.arq.ArqQueue method) (safir.arq.MockArqQueue method) (safir.arq.RedisArqQueue method) (safir.testing.uws.MockUWSJobRunner method) get_job_result() (safir.arq.ArqQueue method) (safir.arq.MockArqQueue method) (safir.arq.RedisArqQueue method) (safir.testing.uws.MockUWSJobRunner method) get_metadata() (in module safir.metadata) get_namespace_objects_for_test() (safir.testing.kubernetes.MockKubernetesApi method)

get_namespaced_custom_object() (safir.testing.kubernetes.MockKubernetesApi method) get_project_url() (in module safir.metadata) get_route_handler() (safir.slack.webhook.SlackRouteErrorHandler method) GitHubAppClientFactory (class in safir.github) GitHubAppInstallationEventAction (class in safir.github.webhooks) GitHubAppInstallationRepositoriesEventAction (class in safir.github.webhooks) GitHubCheckRunAnnotationLevel (class in safir.github.models) GitHubCheckRunConclusion (class in safir.github.models) GitHubCheckRunEventAction (class in safir.github.webhooks) GitHubCheckRunStatus (class in safir.github.models) GitHubCheckSuiteConclusion (class in safir.github.models) GitHubCheckSuiteEventAction (class in safir.github.webhooks) GitHubCheckSuiteStatus (class in safir.github.models) GitHubPullRequestEventAction (class in safir.github.webhooks) GitHubPullState (class in safir.github.models) grace_period (safir.uws.UWSAppSettings attribute)

H

head_branch (safir.github.models.GitHubCheckSuiteModel attribute) head_sha (safir.github.models.GitHubCheckRunModel attribute) (safir.github.models.GitHubCheckSuiteModel attribute) header (safir.models.ErrorLocation attribute) heading (safir.slack.blockkit.SlackCodeBlock attribute) (safir.slack.blockkit.SlackCodeField attribute) (safir.slack.blockkit.SlackTextBlock attribute) (safir.slack.blockkit.SlackTextField attribute)

html_url (safir.github.models.GitHubCheckRunModel attribute) (safir.github.models.GitHubPullRequestModel attribute) (safir.github.models.GitHubRepositoryModel attribute) (safir.github.models.GitHubUserModel attribute) http_client_dependency (in module safir.dependencies.http_client) HTTPClientDependency (class in safir.dependencies.http_client)

I

id (safir.arq.JobMetadata attribute) (safir.arq.JobResult attribute) (safir.github.models.GitHubCheckRunModel attribute) (safir.github.models.GitHubCheckSuiteId attribute) (safir.github.models.GitHubCheckSuiteModel attribute) (safir.github.webhooks.GitHubAppInstallationModel attribute) (safir.metrics.EventMetadata attribute) (safir.uws.JobResult attribute) (safir.uws.SerializedJob attribute) id_column() (safir.database.DatetimeIdCursor static method) in_progress (safir.github.models.GitHubCheckRunStatus attribute) (safir.github.models.GitHubCheckSuiteStatus attribute) IncompatibleSchemaError INFO (safir.logging.LogLevel attribute) initial_pod_phase (safir.testing.kubernetes.MockKubernetesApi attribute) initialize() (safir.arq.RedisArqQueue class method) (safir.dependencies.arq.ArqDependency method) (safir.dependencies.db_session.DatabaseSessionDependency method) (safir.dependencies.metrics.EventDependency method) (safir.dependencies.metrics.EventMaker method) (safir.metrics.EventManager method) (safir.metrics.KafkaEventManager method) (safir.slack.webhook.SlackRouteErrorHandler class method)

initialize_database() (in module safir.database) initialize_fastapi() (safir.uws.UWSApplication method) initialize_kubernetes() (in module safir.kubernetes) install_error_handlers() (safir.uws.UWSApplication method) install_handlers() (safir.uws.UWSApplication method) install_middleware() (safir.uws.UWSApplication method) installation (safir.github.webhooks.GitHubAppInstallationEventModel attribute) (safir.github.webhooks.GitHubAppInstallationRepositoriesEventModel attribute) (safir.github.webhooks.GitHubCheckRunEventModel attribute) (safir.github.webhooks.GitHubCheckSuiteEventModel attribute) (safir.github.webhooks.GitHubPullRequestEventModel attribute) (safir.github.webhooks.GitHubPushEventModel attribute) InvalidAvroNameError InvalidCursorError InvalidMetadataError invert() (safir.database.DatetimeIdCursor method) (safir.database.PaginationCursor method) is_database_current() (in module safir.database) isodatetime() (in module safir.datetime)

J

job_id (safir.arq.ArqJobError attribute) JobMetadata (class in safir.arq) JobNotFound JobNotQueued

JobResult (class in safir.arq) JobResultUnavailable jobs (safir.testing.uws.MockWobbly attribute) json_parameters (safir.uws.JobBase attribute) (safir.uws.JobCreate attribute)

K

kafka (safir.metrics.KafkaMetricsConfiguration attribute) KafkaEventManager (class in safir.metrics) KafkaEventPublisher (class in safir.metrics)

KafkaTopicError kwargs (safir.arq.JobMetadata attribute) (safir.arq.JobResult attribute)

L

labeled (safir.github.webhooks.GitHubPullRequestEventAction attribute) lifetime (safir.uws.UWSAppSettings attribute) link_header() (safir.database.PaginatedList method) list_cluster_custom_object() (safir.testing.kubernetes.MockKubernetesApi method) list_jobs() (safir.testing.uws.MockWobbly method) list_namespace() (safir.testing.kubernetes.MockKubernetesApi method) list_namespaced_custom_object() (safir.testing.kubernetes.MockKubernetesApi method) list_namespaced_event() (safir.testing.kubernetes.MockKubernetesApi method) list_namespaced_ingress() (safir.testing.kubernetes.MockKubernetesApi method) list_namespaced_job() (safir.testing.kubernetes.MockKubernetesApi method) list_namespaced_persistent_volume_claim() (safir.testing.kubernetes.MockKubernetesApi method)

list_namespaced_pod() (safir.testing.kubernetes.MockKubernetesApi method) list_namespaced_service() (safir.testing.kubernetes.MockKubernetesApi method) list_node() (safir.testing.kubernetes.MockKubernetesApi method) loc (safir.models.ErrorDetail attribute) location (safir.fastapi.ClientRequestError attribute) locked (safir.github.webhooks.GitHubPullRequestEventAction attribute) logger (safir.metrics.EventManager attribute) logger_dependency (in module safir.dependencies.logger) LoggerDependency (class in safir.dependencies.logger) login (safir.github.models.GitHubRepoOwnerModel attribute) (safir.github.models.GitHubUserModel attribute) LogLevel (class in safir.logging)

M

make_manager() (safir.kafka.SchemaManagerSettings method) (safir.metrics.BaseMetricsConfiguration method) (safir.metrics.DisabledMetricsConfiguration method) (safir.metrics.KafkaMetricsConfiguration method) (safir.metrics.MockMetricsConfiguration method) make_token() (safir.testing.uws.MockWobbly static method) mark_complete() (safir.testing.uws.MockUWSJobRunner method) mark_in_progress() (safir.testing.uws.MockUWSJobRunner method) max_formatted_length (safir.slack.blockkit.SlackBaseBlock attribute) (safir.slack.blockkit.SlackBaseField attribute) merged (safir.github.models.GitHubPullRequestModel attribute) message (safir.slack.blockkit.SlackException attribute) (safir.slack.blockkit.SlackMessage attribute) (safir.uws.JobError attribute) message_id (safir.uws.JobUpdateQueued attribute) (safir.uws.SerializedJob attribute) messages (safir.testing.slack.MockSlackWebhook attribute) metrics_configuration_factory() (in module safir.metrics) MetricsConfiguration (in module safir.metrics) milestoned (safir.github.webhooks.GitHubPullRequestEventAction attribute) mime_type (safir.arq.uws.WorkerResult attribute) (safir.uws.JobResult attribute) mock (safir.metrics.MockMetricsConfiguration attribute) mock_slack_webhook() (in module safir.testing.slack) MockArqQueue (class in safir.arq) MockBlob (class in safir.testing.gcs) MockBucket (class in safir.testing.gcs) MockEventManager (class in safir.metrics) MockEventPublisher (class in safir.metrics) MockKubernetesApi (class in safir.testing.kubernetes) MockSlackWebhook (class in safir.testing.slack) MockStorageClient (class in safir.testing.gcs) MockUWSJobRunner (class in safir.testing.uws) MockWobbly (class in safir.testing.uws) model_dump() (safir.pydantic.CamelCaseModel method) model_dump_json() (safir.pydantic.CamelCaseModel method) module safir safir.arq safir.arq.uws safir.asyncio safir.click safir.database safir.datetime safir.dependencies.arq safir.dependencies.db_session safir.dependencies.gafaelfawr safir.dependencies.http_client safir.dependencies.logger safir.dependencies.metrics safir.fastapi safir.gcs safir.github safir.github.models safir.github.webhooks safir.kafka safir.kubernetes safir.logging safir.metadata safir.metrics safir.middleware.ivoa safir.middleware.x_forwarded safir.models safir.pydantic safir.redis safir.slack.blockkit safir.slack.webhook safir.testing.gcs safir.testing.kubernetes safir.testing.slack safir.testing.uvicorn safir.testing.uws safir.uws

msg (safir.models.ErrorDetail attribute)

N

name (safir.arq.JobMetadata attribute) (safir.arq.JobResult attribute) (safir.github.models.GitHubBranchModel attribute) (safir.github.models.GitHubCheckRunModel attribute) (safir.github.models.GitHubRepositoryModel attribute) (safir.github.webhooks.GitHubAppInstallationEventRepoModel attribute) (safir.metadata.Metadata attribute) neutral (safir.github.models.GitHubCheckRunConclusion attribute) (safir.github.models.GitHubCheckSuiteConclusion attribute) new_permissions_accepted (safir.github.webhooks.GitHubAppInstallationEventAction attribute) next_url() (safir.database.PaginatedList method)

NONE (safir.kafka.Compatibility attribute) NoopEventManager (class in safir.metrics) NoopEventPublisher (class in safir.metrics) normalize_datetime() (in module safir.pydantic) normalize_isodatetime() (in module safir.pydantic) NOT_NONE (in module safir.metrics) notice (safir.github.models.GitHubCheckRunAnnotationLevel attribute) NotPublishedConsecutivelyError NotPublishedError number (safir.github.models.GitHubPullRequestModel attribute) (safir.github.webhooks.GitHubPullRequestEventModel attribute)

O

on_shutdown (safir.arq.WorkerSettings attribute) on_startup (safir.arq.WorkerSettings attribute) open (safir.github.models.GitHubPullState attribute) opened (safir.github.webhooks.GitHubPullRequestEventAction attribute)

output (safir.github.models.GitHubCheckRunModel attribute) override_arq_queue() (safir.uws.UWSApplication method) owner (safir.github.models.GitHubRepositoryModel attribute) (safir.uws.SerializedJob attribute) owner_name (safir.github.webhooks.GitHubAppInstallationEventRepoModel property)

P

PaginatedList (class in safir.database) PaginatedQueryRunner (class in safir.database) PaginationCursor (class in safir.database) PaginationLinkData (class in safir.database) ParameterError parameters (safir.uws.Job attribute) parse_isodatetime() (in module safir.datetime) parse_timedelta() (in module safir.datetime) patch_google_storage() (in module safir.testing.gcs) patch_kubernetes() (in module safir.testing.kubernetes) patch_namespaced_custom_object_status() (safir.testing.kubernetes.MockKubernetesApi method) patch_namespaced_ingress_status() (safir.testing.kubernetes.MockKubernetesApi method) patch_namespaced_pod_status() (safir.testing.kubernetes.MockKubernetesApi method) patch_namespaced_secret() (safir.testing.kubernetes.MockKubernetesApi method) patch_wobbly() (in module safir.testing.uws) path (safir.models.ErrorLocation attribute) phase (safir.uws.JobUpdateAborted attribute) (safir.uws.JobUpdateCompleted attribute) (safir.uws.JobUpdateError attribute) (safir.uws.JobUpdateExecuting attribute) (safir.uws.JobUpdateMetadata attribute) (safir.uws.JobUpdateQueued attribute) (safir.uws.SerializedJob attribute) PLAIN (safir.kafka.SaslMechanism attribute) PLAINTEXT (safir.kafka.SecurityProtocol attribute) post() (safir.slack.webhook.SlackWebhookClient method)

post_exception() (safir.slack.webhook.SlackWebhookClient method) post_uncaught_exception() (safir.slack.webhook.SlackWebhookClient method) post_webhook() (safir.testing.slack.MockSlackWebhook method) prev_url() (safir.database.PaginatedList method) production (safir.arq.ArqMode attribute) (safir.logging.Profile attribute) Profile (class in safir.logging) publish() (safir.metrics.EventPublisher method) (safir.metrics.KafkaEventManager method) (safir.metrics.KafkaEventPublisher method) (safir.metrics.MockEventPublisher method) (safir.metrics.NoopEventPublisher method) published (safir.metrics.MockEventPublisher attribute) PublishedCountError PublishedList (class in safir.metrics) PublishedTooFewError pull_request (safir.github.webhooks.GitHubPullRequestEventModel attribute) pull_requests (safir.github.models.GitHubCheckRunModel attribute) (safir.github.models.GitHubCheckSuiteModel attribute) put() (safir.asyncio.AsyncMultiQueue method) PydanticRedisStorage (class in safir.redis) PydanticSchemaManager (class in safir.kafka) Python Enhancement Proposals PEP 440, [1] PEP 484 PEP 8

Q

qsize() (safir.asyncio.AsyncMultiQueue method) query (safir.models.ErrorLocation attribute) query_count() (safir.database.PaginatedQueryRunner method) query_object() (safir.database.CountedPaginatedQueryRunner method) (safir.database.PaginatedQueryRunner method) query_row() (safir.database.CountedPaginatedQueryRunner method) (safir.database.PaginatedQueryRunner method)

queue_name (safir.arq.JobMetadata attribute) (safir.arq.WorkerSettings attribute) queued (safir.github.models.GitHubCheckRunStatus attribute) (safir.github.models.GitHubCheckSuiteStatus attribute) quote (safir.uws.SerializedJob attribute)

R

read_namespace() (safir.testing.kubernetes.MockKubernetesApi method) read_namespaced_config_map() (safir.testing.kubernetes.MockKubernetesApi method) read_namespaced_ingress() (safir.testing.kubernetes.MockKubernetesApi method) read_namespaced_job() (safir.testing.kubernetes.MockKubernetesApi method) read_namespaced_network_policy() (safir.testing.kubernetes.MockKubernetesApi method) read_namespaced_persistent_volume_claim() (safir.testing.kubernetes.MockKubernetesApi method) read_namespaced_pod() (safir.testing.kubernetes.MockKubernetesApi method) read_namespaced_pod_status() (safir.testing.kubernetes.MockKubernetesApi method) read_namespaced_resource_quota() (safir.testing.kubernetes.MockKubernetesApi method) read_namespaced_secret() (safir.testing.kubernetes.MockKubernetesApi method) read_namespaced_service() (safir.testing.kubernetes.MockKubernetesApi method) ready_for_review (safir.github.webhooks.GitHubPullRequestEventAction attribute) RedisArqQueue (class in safir.arq) ref (safir.github.webhooks.GitHubPushEventModel attribute) register_model() (safir.kafka.PydanticSchemaManager method) registry_url (safir.kafka.SchemaManagerSettings attribute) removed (safir.github.webhooks.GitHubAppInstallationRepositoriesEventAction attribute) reopened (safir.github.webhooks.GitHubPullRequestEventAction attribute) replace_namespaced_custom_object() (safir.testing.kubernetes.MockKubernetesApi method) replace_namespaced_secret() (safir.testing.kubernetes.MockKubernetesApi method) repositories (safir.github.webhooks.GitHubAppInstallationEventModel attribute) repositories_added (safir.github.webhooks.GitHubAppInstallationRepositoriesEventModel attribute) repositories_removed (safir.github.webhooks.GitHubAppInstallationRepositoriesEventModel attribute)

repository (safir.github.webhooks.GitHubCheckRunEventModel attribute) (safir.github.webhooks.GitHubCheckSuiteEventModel attribute) (safir.github.webhooks.GitHubPullRequestEventModel attribute) (safir.github.webhooks.GitHubPushEventModel attribute) repository_url (safir.metadata.Metadata attribute) requested (safir.github.webhooks.GitHubCheckSuiteEventAction attribute) requested_action (safir.github.webhooks.GitHubCheckRunEventAction attribute) rerequested (safir.github.webhooks.GitHubCheckRunEventAction attribute) (safir.github.webhooks.GitHubCheckSuiteEventAction attribute) result (safir.arq.JobResult attribute) result_id (safir.arq.uws.WorkerResult attribute) results (safir.uws.JobUpdateCompleted attribute) (safir.uws.SerializedJob attribute) retry_async_transaction() (in module safir.database) review_request_removed (safir.github.webhooks.GitHubPullRequestEventAction attribute) review_requested (safir.github.webhooks.GitHubPullRequestEventAction attribute) RFC RFC 8288, [1], [2], [3], [4], [5] run_id (safir.arq.uws.WorkerJobInfo attribute) (safir.uws.JobBase attribute) (safir.uws.JobCreate attribute) run_migrations_offline() (in module safir.database) run_migrations_online() (in module safir.database) run_with_asyncio() (in module safir.asyncio)

S

safir module safir.arq module safir.arq.uws module safir.asyncio module safir.click module safir.database module safir.datetime module safir.dependencies.arq module safir.dependencies.db_session module safir.dependencies.gafaelfawr module safir.dependencies.http_client module safir.dependencies.logger module safir.dependencies.metrics module safir.fastapi module safir.gcs module safir.github module safir.github.models module safir.github.webhooks module safir.kafka module safir.kubernetes module safir.logging module safir.metadata module safir.metrics module safir.middleware.ivoa module safir.middleware.x_forwarded module safir.models module safir.pydantic module safir.redis module safir.slack.blockkit module safir.slack.webhook module safir.testing.gcs module safir.testing.kubernetes module safir.testing.slack module safir.testing.uvicorn module safir.testing.uws module safir.uws module sasl_mechanism (safir.kafka.KafkaConnectionSettings attribute) (safir.kafka.SaslPlaintextSettings attribute) (safir.kafka.SaslSslSettings attribute)

sasl_password (safir.kafka.KafkaConnectionSettings attribute) (safir.kafka.SaslPlaintextSettings attribute) (safir.kafka.SaslSslSettings attribute) SASL_PLAINTEXT (safir.kafka.SecurityProtocol attribute) SASL_SSL (safir.kafka.SecurityProtocol attribute) sasl_username (safir.kafka.KafkaConnectionSettings attribute) (safir.kafka.SaslPlaintextSettings attribute) (safir.kafka.SaslSslSettings attribute) SaslMechanism (class in safir.kafka) scan() (safir.redis.EncryptedPydanticRedisStorage method) (safir.redis.PydanticRedisStorage method) schema_manager (safir.metrics.KafkaMetricsConfiguration attribute) SchemaInfo (class in safir.kafka) SchemaRegistryClientParams (class in safir.kafka) SCRAM_SHA_256 (safir.kafka.SaslMechanism attribute) SCRAM_SHA_512 (safir.kafka.SaslMechanism attribute) security_protocol (safir.kafka.KafkaConnectionSettings attribute) (safir.kafka.PlaintextSettings attribute) (safir.kafka.SaslPlaintextSettings attribute) (safir.kafka.SaslSslSettings attribute) (safir.kafka.SslSettings attribute) SecurityProtocol (class in safir.kafka) serialize() (safir.kafka.PydanticSchemaManager method) ServerNotListeningError service (safir.uws.SerializedJob attribute) service_account (safir.uws.UWSAppSettings attribute) set_complete() (safir.arq.MockArqQueue method) set_in_progress() (safir.arq.MockArqQueue method) set_nodes_for_test() (safir.testing.kubernetes.MockKubernetesApi method) sha (safir.github.models.GitHubBlobModel attribute) (safir.github.models.GitHubBranchCommitModel attribute) shutdown_fastapi() (safir.uws.UWSApplication method) signed_url() (safir.gcs.SignedURLService method) SignedURLService (class in safir.gcs) size (safir.arq.uws.WorkerResult attribute) (safir.github.models.GitHubBlobModel attribute) (safir.uws.JobResult attribute) slack_webhook (safir.uws.UWSConfig attribute) SlackException SlackIgnoredException SlackRouteErrorHandler (class in safir.slack.webhook) SlackWebException SlackWebhookClient (class in safir.slack.webhook) spawn_uvicorn() (in module safir.testing.uvicorn) SSL (safir.kafka.SecurityProtocol attribute) stale (safir.github.models.GitHubCheckRunConclusion attribute) (safir.github.models.GitHubCheckSuiteConclusion attribute) stamp_database() (in module safir.database) stamp_database_async() (in module safir.database) start_time (safir.arq.JobResult attribute) (safir.uws.JobUpdateExecuting attribute) (safir.uws.SerializedJob attribute) state (safir.github.models.GitHubPullRequestModel attribute) status (safir.arq.JobMetadata attribute) (safir.arq.JobResult attribute) (safir.github.models.GitHubCheckRunModel attribute) (safir.github.models.GitHubCheckSuiteModel attribute) storage_url (safir.uws.UWSAppSettings attribute) store() (safir.redis.EncryptedPydanticRedisStorage method) (safir.redis.PydanticRedisStorage method) strip_none() (in module safir.testing.kubernetes) success (safir.arq.JobResult attribute) (safir.github.models.GitHubCheckRunConclusion attribute) (safir.github.models.GitHubCheckSuiteConclusion attribute) suffix (safir.kafka.SchemaManagerSettings attribute) summary (safir.github.models.GitHubCheckRunOutput attribute) suspend (safir.github.webhooks.GitHubAppInstallationEventAction attribute) sync_get_route (safir.uws.UWSConfig attribute) sync_post_route (safir.uws.UWSConfig attribute) sync_timeout (safir.uws.UWSAppSettings attribute) (safir.uws.UWSConfig attribute) synchronize (safir.github.webhooks.GitHubPullRequestEventAction attribute)

T

T (in module safir.arq.uws) test (safir.arq.ArqMode attribute) text (safir.github.models.GitHubCheckRunOutput attribute) (safir.slack.blockkit.SlackTextBlock attribute) (safir.slack.blockkit.SlackTextField attribute) time_column() (safir.database.DatetimeIdCursor static method) timed_out (safir.github.models.GitHubCheckRunConclusion attribute) (safir.github.models.GitHubCheckSuiteConclusion attribute) timeout (safir.uws.UWSAppSettings attribute) timestamp (safir.metrics.EventMetadata attribute) timestamp_ns (safir.metrics.EventMetadata attribute) title (safir.github.models.GitHubCheckRunOutput attribute) (safir.github.models.GitHubPullRequestModel attribute) to_aiokafka_params() (safir.kafka.KafkaConnectionSettings method) (safir.kafka.PlaintextSettings method) (safir.kafka.SaslPlaintextSettings method) (safir.kafka.SaslSslSettings method) (safir.kafka.SslSettings method) to_camel_case() (in module safir.pydantic) to_faststream_params() (safir.kafka.KafkaConnectionSettings method) (safir.kafka.PlaintextSettings method) (safir.kafka.SaslPlaintextSettings method) (safir.kafka.SaslSslSettings method) (safir.kafka.SslSettings method)

to_job_description() (safir.uws.SerializedJob method) to_registry_params() (safir.kafka.SchemaManagerSettings method) to_serialized_job() (safir.uws.Job method) to_slack() (safir.slack.blockkit.SlackBaseBlock method) (safir.slack.blockkit.SlackCodeBlock method) (safir.slack.blockkit.SlackMessage method) (safir.slack.blockkit.SlackTextBlock method) to_ssl_context() (safir.kafka.SaslSslSettings method) (safir.kafka.SslSettings method) to_worker_parameters() (safir.uws.ParametersModel method) to_xml_model() (safir.uws.Job method) (safir.uws.JobError method) (safir.uws.JobResult method) (safir.uws.ParametersModel method) topic (safir.metrics.EventManager attribute) topic_prefix (safir.metrics.EventsConfiguration attribute) traceback (safir.arq.uws.WorkerError attribute) TRANSIENT (safir.arq.uws.WorkerErrorType attribute) trees_url (safir.github.models.GitHubRepositoryModel attribute) type (safir.models.ErrorDetail attribute) (safir.uws.JobError attribute)

U

unassigned (safir.github.webhooks.GitHubPullRequestEventAction attribute) UnknownDeserializeError UnknownSchemaError unlabeled (safir.github.webhooks.GitHubPullRequestEventAction attribute) unlocked (safir.github.webhooks.GitHubPullRequestEventAction attribute) unstamp_database() (in module safir.database) unsuspend (safir.github.webhooks.GitHubAppInstallationEventAction attribute) update_job() (safir.testing.uws.MockWobbly method) url (safir.arq.uws.WorkerResult attribute) (safir.github.models.GitHubBlobModel attribute) (safir.github.models.GitHubBranchCommitModel attribute) (safir.github.models.GitHubCheckRunModel attribute) (safir.github.models.GitHubCheckRunPrInfoModel attribute) (safir.github.models.GitHubCheckSuiteModel attribute) (safir.github.models.GitHubUserModel attribute) (safir.testing.slack.MockSlackWebhook attribute) (safir.uws.JobResult attribute)

url_lifetime (safir.uws.UWSConfig attribute) USAGE (safir.arq.uws.WorkerErrorType attribute) UsageError user (safir.arq.uws.WorkerError attribute) (safir.github.models.GitHubPullRequestModel attribute) (safir.slack.blockkit.SlackException attribute) UvicornProcess (class in safir.testing.uvicorn) UWS_QUEUE_NAME (in module safir.arq.uws) UWSApplication (class in safir.uws) UWSConfig (class in safir.uws) UWSError UWSRoute (class in safir.uws)

V

validate_auth_settings() (safir.kafka.KafkaConnectionSettings method) validate_destruction (safir.uws.UWSConfig attribute) validate_exactly_one_of() (in module safir.pydantic) validate_execution_duration (safir.uws.UWSConfig attribute)

validate_structure() (safir.metrics.EventPayload class method) validated (safir.kafka.KafkaConnectionSettings property) verbatim (safir.slack.blockkit.SlackMessage attribute) version (safir.metadata.Metadata attribute)

W

wait_timeout (safir.uws.UWSConfig attribute) warning (safir.github.models.GitHubCheckRunAnnotationLevel attribute) WARNING (safir.logging.LogLevel attribute) wobbly_url (safir.uws.UWSAppSettings attribute) WorkerConfig (class in safir.arq.uws) WorkerError

WorkerErrorType (class in safir.arq.uws) WorkerFatalError WorkerJobInfo (class in safir.arq.uws) WorkerSettings (class in safir.arq) WorkerTimeoutError WorkerTransientError WorkerUsageError

X

XForwardedMiddleware (class in safir.middleware.x_forwarded)