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) annotations (in module safir.kubernetes) 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) 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_namespaced_config_map() (safir.testing.kubernetes.MockKubernetesApi method) create_namespaced_custom_object() (safir.testing.kubernetes.MockKubernetesApi method) create_namespaced_pod() (safir.testing.kubernetes.MockKubernetesApi method) create_namespaced_secret() (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_namespaced_config_map() (safir.testing.kubernetes.MockKubernetesApi method) delete_namespaced_pod() (safir.testing.kubernetes.MockKubernetesApi method) development (safir.logging.Profile attribute) dict() (safir.pydantic.CamelCaseModel method) dispatch() (safir.middleware.ivoa.CaseInsensitiveQueryMiddleware method) (safir.middleware.x_forwarded.XForwardedMiddleware method)

E

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) ErrorDetail (class in safir.models) ErrorLocation (class in safir.models) ErrorModel (class in safir.models)

F

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_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_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) 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_namespaced_pod() (safir.testing.kubernetes.MockKubernetesApi method) 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.SlackCodeBlock attribute) (safir.slack.blockkit.SlackTextBlock 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.gcs safir.kubernetes safir.logging safir.metadata safir.middleware.ivoa safir.middleware.x_forwarded safir.models safir.pydantic 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) Python Enhancement Proposals PEP 440, [1] PEP 484 PEP 8

Q

query (safir.models.ErrorLocation attribute)

queue_name (safir.arq.JobMetadata attribute)

R

read_namespaced_pod() (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

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.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.slack.blockkit module safir.slack.webhook module safir.testing.gcs module safir.testing.kubernetes module safir.testing.slack module safir.testing.uvicorn module ServerNotListeningError set_complete() (safir.arq.MockArqQueue method) set_in_progress() (safir.arq.MockArqQueue 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) 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) 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)