Index

_

__call__() (safir.dependencies.arq.ArqDependency method) (safir.dependencies.db_session.DatabaseSessionDependency method) (safir.dependencies.http_client.HTTPClientDependency method) (safir.dependencies.logger.LoggerDependency method)

__version__ (in module safir)

A

aclose() (safir.dependencies.db_session.DatabaseSessionDependency method) (safir.dependencies.http_client.HTTPClientDependency method) add_log_severity() (in module safir.logging) args (safir.arq.JobMetadata attribute) (safir.arq.JobResult attribute) arq_dependency (in module safir.dependencies.arq)

ArqDependency (class in safir.dependencies.arq) ArqJobError ArqMode (class in safir.arq) ArqQueue (class in safir.arq) auth_dependency() (in module safir.dependencies.gafaelfawr) auth_logger_dependency() (in module safir.dependencies.gafaelfawr)

B

blob() (safir.testing.gcs.MockBucket method)

body (safir.models.ErrorLocation attribute) bucket() (safir.testing.gcs.MockStorageClient method)

C

CamelCaseModel (class in safir.pydantic) CaseInsensitiveQueryMiddleware (class in safir.middleware.ivoa) client_request_error_handler() (in module safir.fastapi) ClientRequestError configure_logging() (in module safir.logging) configure_uvicorn_logging() (in module safir.logging) create_async_session() (in module safir.database) create_database_engine() (in module safir.database) 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_network_policy() (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_sync_session() (in module safir.database) CRITICAL (safir.logging.LogLevel 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) db_session_dependency (in module safir.dependencies.db_session) DEBUG (safir.logging.LogLevel 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_pod() (safir.testing.kubernetes.MockKubernetesApi method) DeserializeError development (safir.logging.Profile attribute) dict() (safir.pydantic.CamelCaseModel method) dispatch() (safir.middleware.ivoa.CaseInsensitiveQueryMiddleware method) (safir.middleware.x_forwarded.XForwardedMiddleware method)

E

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) error_callback (safir.testing.kubernetes.MockKubernetesApi attribute) ErrorDetail (class in safir.models) ErrorLocation (class in safir.models) ErrorModel (class in safir.models)

F

field_path (safir.fastapi.ClientRequestError attribute) finish_time (safir.arq.JobResult attribute)

format_datetime_for_logging() (in module safir.datetime) from_job() (safir.arq.JobMetadata class method) (safir.arq.JobResult class method)

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_job_metadata() (safir.arq.ArqQueue method) (safir.arq.MockArqQueue method) (safir.arq.RedisArqQueue method)

get_job_result() (safir.arq.ArqQueue method) (safir.arq.MockArqQueue method) (safir.arq.RedisArqQueue 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)

H

header (safir.models.ErrorLocation 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) 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.slack.webhook.SlackRouteErrorHandler class method)

initialize_database() (in module safir.database) initialize_kubernetes() (in module safir.kubernetes) 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 json() (safir.pydantic.CamelCaseModel method)

K

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

L

list_cluster_custom_object() (safir.testing.kubernetes.MockKubernetesApi method) list_namespace() (safir.testing.kubernetes.MockKubernetesApi method) list_namespaced_event() (safir.testing.kubernetes.MockKubernetesApi method) list_namespaced_pod() (safir.testing.kubernetes.MockKubernetesApi method) list_node() (safir.testing.kubernetes.MockKubernetesApi method)

location (safir.fastapi.ClientRequestError attribute) logger_dependency (in module safir.dependencies.logger) logger_name (in module safir.logging) LoggerDependency (class in safir.dependencies.logger) LogLevel (class in safir.logging)

M

max_formatted_length (safir.slack.blockkit.SlackBaseBlock attribute) (safir.slack.blockkit.SlackBaseField attribute) messages (safir.testing.slack.MockSlackWebhook attribute) Metadata (class in safir.metadata) 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) module safir safir.arq safir.asyncio safir.database safir.datetime safir.dependencies.arq safir.dependencies.db_session safir.dependencies.gafaelfawr safir.dependencies.http_client safir.dependencies.logger safir.fastapi safir.gcs safir.kubernetes safir.logging safir.metadata 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

N

name (safir.arq.JobMetadata attribute) (safir.arq.JobResult attribute)

normalize_datetime() (in module safir.pydantic) normalize_isodatetime() (in module safir.pydantic)

O

override_engine() (safir.dependencies.db_session.DatabaseSessionDependency method)

P

parse_isodatetime() (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_secret() (safir.testing.kubernetes.MockKubernetesApi method) path (safir.models.ErrorLocation 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) production (safir.arq.ArqMode attribute) (safir.logging.Profile attribute) Profile (class in safir.logging) PydanticRedisStorage (class in safir.redis) Python Enhancement Proposals PEP 440, [1] PEP 484 PEP 8

Q

query (safir.models.ErrorLocation attribute)

queue_name (safir.arq.JobMetadata attribute)

R

read_namespace() (safir.testing.kubernetes.MockKubernetesApi method) read_namespaced_pod() (safir.testing.kubernetes.MockKubernetesApi method) read_namespaced_pod_status() (safir.testing.kubernetes.MockKubernetesApi method) read_namespaced_secret() (safir.testing.kubernetes.MockKubernetesApi method)

RedisArqQueue (class in safir.arq) replace_namespaced_custom_object() (safir.testing.kubernetes.MockKubernetesApi method) replace_namespaced_secret() (safir.testing.kubernetes.MockKubernetesApi method) result (safir.arq.JobResult attribute) run_with_asyncio() (in module safir.asyncio)

S

S (in module safir.redis) safir module safir.arq module safir.asyncio 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.fastapi module safir.gcs module safir.kubernetes module safir.logging module safir.metadata 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 scan() (safir.redis.EncryptedPydanticRedisStorage method) (safir.redis.PydanticRedisStorage method) ServerNotListeningError set_complete() (safir.arq.MockArqQueue method) set_in_progress() (safir.arq.MockArqQueue method) set_nodes_for_test() (safir.testing.kubernetes.MockKubernetesApi method) signed_url() (safir.gcs.SignedURLService method) SignedURLService (class in safir.gcs) SlackBaseBlock (class in safir.slack.blockkit) SlackBaseField (class in safir.slack.blockkit) SlackCodeBlock (class in safir.slack.blockkit) SlackCodeField (class in safir.slack.blockkit) SlackException SlackIgnoredException SlackMessage (class in safir.slack.blockkit) SlackRouteErrorHandler (class in safir.slack.webhook) SlackTextBlock (class in safir.slack.blockkit) SlackTextField (class in safir.slack.blockkit) SlackWebException SlackWebhookClient (class in safir.slack.webhook) spawn_uvicorn() (in module safir.testing.uvicorn) start_time (safir.arq.JobResult attribute) status (safir.arq.JobMetadata attribute) (safir.arq.JobResult attribute) store() (safir.redis.EncryptedPydanticRedisStorage method) (safir.redis.PydanticRedisStorage method) strip_none() (in module safir.testing.kubernetes) success (safir.arq.JobResult attribute)

T

test (safir.arq.ArqMode attribute) to_camel_case() (in module safir.pydantic) to_slack() (safir.slack.blockkit.SlackBaseBlock method) (safir.slack.blockkit.SlackCodeBlock method) (safir.slack.blockkit.SlackMessage method) (safir.slack.blockkit.SlackTextBlock method)

U

url (safir.testing.slack.MockSlackWebhook attribute)

UvicornProcess (class in safir.testing.uvicorn)

V

validate_exactly_one_of() (in module safir.pydantic)

version_info (in module safir)

W

WARNING (safir.logging.LogLevel attribute)

X

XForwardedMiddleware (class in safir.middleware.x_forwarded)