Check if a source's async processing is complete. Returns True if processing is complete (success or failure), False if stil

Compatibility handler for pre-1.6 queued embed_chunk jobs. The legacy vectorizer stored the full chunk payload in each job. Keeping this

Compatibility handler for pre-1.6 queued embed_single_item jobs. New code submits embed_source, embed_note, or embed_insight directly. This

Compatibility handler for pre-1.6 queued vectorize_source jobs. The old command submitted one job per chunk. Current embed_source does the

Lifespan event handler for the FastAPI application. Runs database migrations automatically on startup.

List command jobs with optional filtering

List all credentials, optionally filtered by provider.

List all credentials for a specific provider.

List all available episode profiles

List available languages as BCP 47 locale codes (e.g. pt-BR, en-US).

List all podcast episodes

List all available speaker profiles

Migrate API keys from environment variables to credential records. Returns dict with message, migrated, skipped, not_configured, errors.

Migrate API keys from environment variables to credential records.

Migrate existing ProviderConfig data to individual credential records. Returns dict with message, migrated, skipped, errors.

Migrate existing ProviderConfig data to individual credential records.

Check if migration is needed (sync wrapper).

Parse command field to ensure RecordID format

Parse id field to handle both string and RecordID inputs

Parse form data into SourceCreate model and return upload file separately.

Update model attributes from dictionary and save

Process source content using the source_graph workflow

Example command for text processing. Tests basic command functionality and demonstrates different processing types.

Provision environment variables from database for all providers. NOTE: This function is deprecated for request-time use because it can leave

Rebuild embeddings in bulk. Note: This operation can take a long time for large databases. Consider increasing API_CLIENT_TIMEOUT to

Rebuild embeddings for sources, notes, and/or insights. This command submits individual embedding jobs for each item: - embed_source for

Register discovered models and link them to this credential.

Remove a source from a notebook (delete the reference).

Retry a failed podcast episode by deleting it and submitting a new job

Retry processing for a failed or stuck source.

Run the async function in a new event loop

Run the async function in a new event loop

Run migrations (sync wrapper).

Run one down migration.

Run one up migration.