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.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) 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) 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) AUTHENTICATION_ERROR (safir.uws.ErrorCode attribute) AUTHORIZATION_ERROR (safir.uws.ErrorCode attribute) 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) 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.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) 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) 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) 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_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) CRITICAL (safir.logging.LogLevel attribute) cron_jobs (safir.arq.WorkerSettings attribute) current_datetime() (in module safir.datetime)

D

database_password (safir.uws.UWSAppSettings attribute) (safir.uws.UWSConfig attribute) database_url (safir.uws.UWSAppSettings attribute) DatabaseInitializationError DatabaseSchemaError 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_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 detail (safir.arq.uws.WorkerError attribute) (safir.models.ErrorModel attribute) (safir.uws.UWSJobError 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) encoding (safir.github.models.GitHubBlobModel attribute) EncryptedPydanticRedisStorage (class in safir.redis) 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) (safir.uws.ErrorCode attribute)

error_callback (safir.testing.kubernetes.MockKubernetesApi attribute) error_type (safir.arq.uws.WorkerError attribute) ErrorCode (class in safir.uws) ErrorLocation (class in safir.models) 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) 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_job() (safir.arq.JobMetadata class method) (safir.arq.JobResult class method) from_job_parameters() (safir.uws.ParametersModel class method) from_str() (safir.database.DatetimeIdCursor class method) (safir.database.PaginationCursor 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_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) 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) initialize_uws_database() (safir.uws.UWSApplication method) 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 InvalidMetadataError invert() (safir.database.DatetimeIdCursor method) (safir.database.PaginationCursor method) is_database_current() (in module safir.database) is_schema_current() (safir.uws.UWSApplication method) 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

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_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) 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) messages (safir.testing.slack.MockSlackWebhook attribute) metadata (safir.uws.UWSSchemaBase 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.UWSJobResult 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) MockKubernetesApi (class in safir.testing.kubernetes) MockSlackWebhook (class in safir.testing.slack) MockStorageClient (class in safir.testing.gcs) MockUWSJobRunner (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) MULTIVALUED_PARAM_NOT_SUPPORTED (safir.uws.ErrorCode attribute) MultiValuedParameterError

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_cursor (safir.database.PaginatedList 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) notice (safir.github.models.GitHubCheckRunAnnotationLevel attribute) 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) owner_name (safir.github.webhooks.GitHubAppInstallationEventRepoModel property)

P

PaginatedList (class in safir.database) PaginatedQueryRunner (class in safir.database) PaginationCursor (class in safir.database) ParameterError ParameterParseError 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) path (safir.models.ErrorLocation 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_cursor (safir.database.PaginatedList attribute) 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.NoopEventPublisher method) 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_object() (safir.database.PaginatedQueryRunner method) query_row() (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)

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 (safir.uws.UWSSchemaBase attribute) 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) 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 run_id (safir.arq.uws.WorkerJobInfo 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_account (safir.uws.UWSAppSettings attribute) SERVICE_UNAVAILABLE (safir.uws.ErrorCode 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.UWSJobResult 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) 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_dict() (safir.uws.UWSJobError method) (safir.uws.UWSJobParameter method) to_faststream_params() (safir.kafka.KafkaConnectionSettings method) (safir.kafka.PlaintextSettings method) (safir.kafka.SaslPlaintextSettings method) (safir.kafka.SaslSslSettings method) (safir.kafka.SslSettings method)

to_registry_params() (safir.kafka.SchemaManagerSettings 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.UWSJob method) (safir.uws.UWSJobError method) (safir.uws.UWSJobParameter method) (safir.uws.UWSJobResult 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)

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) 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) url_lifetime (safir.uws.UWSConfig attribute) USAGE (safir.arq.uws.WorkerErrorType attribute)

USAGE_ERROR (safir.uws.ErrorCode 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_post_params_dependency() (in module safir.uws) UWS_QUEUE_NAME (in module safir.arq.uws) UWSApplication (class in safir.uws) UWSConfig (class in safir.uws) UWSError UWSJob (class in safir.uws) UWSJobError (class in safir.uws) UWSJobParameter (class in safir.uws) UWSJobResult (class in safir.uws) UWSRoute (class in safir.uws) UWSSchemaBase (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) 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)