Common handling for POST /generate/async responses. Returns the request id on success, ``None`` otherwise. 429 (rate limit) and selected 403

Helper: async → pop → submit → retrieve a single text generation. Returns the retrieved generation dict so callers can assert on specific fields.

Cancel an unfinished request. This request will include all already generated images in base64 encoded .webp files.

Generate a presigned Amazon S3 URL that can be used to perform an action. :param s3_client: A Boto3 Amazon S3 client. :param client_

Configure Logfire and instrument Flask + outbound HTTP + loguru. Must be invoked before any other ``before_request`` registration so OTel's s

Prepares the prompt to be scanned by the regex, by removing tricks one might use to avoid the filters

Return a context manager + assertion helper for SQL-count regressions. Usage: with assert_query_count() as queries: user.trus

Extend this function to add extra kudos burn for the particular use Which represents the cost of each job to the horde infrastructure

Hook for json.loads to convert ISO 8601 strings back to datetime objects. Uses a pre-compiled regex for efficiency.

Cancel an unfinished request. This request will include all already generated texts.

Deletes an IP address in timeout

Returns all known IP block timeouts

Extendable class to retrieve the sorted WP list for this worker

Returns False if the IP is not false Else return true This function is a bit obscured with env vars to prevent defeat

Factory: attach a ``UserRole`` to a user.

Filter statements by leading SQL keyword (e.g. ``SELECT``).

Submit aesthetic ratings for generated images to be used by LAION and Stability.AI The request has to have been sent as shared: true.

Checks if the IP is in a block timeout

Stores the safety of the IP in redis temporarily

Return ``value`` as an int4-representable user id, or None if it cannot be (unparseable, negative, or out of range). Guards id-based user lookups

Flush the (fake) redis caches to simulate the 30s worker/user cache TTL elapsing, so a read-after-write reflects committed DB state rather than a

Print a failure bucket to stderr and return its total occurrence count.

Create or rotate one test user and return the raw API key, or None on failure.

After a user passes the evaluation threshold (?? kudos) All the evaluating Kudos added to their total and they automatically become trusted