ocrd_network.database module

The database is used to store information regarding jobs and workspaces.

Jobs: for every process-request a job is inserted into the database with an uuid, status and information about the process like parameters and file groups. It is mainly used to track the status (ocrd_network.models.job.StateEnum) of a job so that the state of a job can be queried. Finished jobs are not deleted from the database.

Workspaces: A job or a processor always runs on a workspace. So a processor needs the information where the workspace is available. This information can be set with providing an absolute path or a workspace_id. With the latter, the database is used to convert the workspace_id to a path.

XXX: Currently the information is not preserved after the processing-server shuts down as the database (runs in docker) currently has no volume set.

async ocrd_network.database.initiate_database(db_url: str)

ocrd_network.database.sync_initiate_database(db_url: str)

async ocrd_network.database.db_create_workspace(mets_path: str) → DBWorkspace

Create a workspace-database entry only from a mets-path

async ocrd_network.database.db_get_workspace(workspace_id: str | None = None, workspace_mets_path: str | None = None) → DBWorkspace

ocrd_network.database.sync_db_get_workspace(workspace_id: str = None, workspace_mets_path: str = None) → DBWorkspace

async ocrd_network.database.db_update_workspace(workspace_id: str | None = None, workspace_mets_path: str | None = None, **kwargs) → DBWorkspace

ocrd_network.database.sync_db_update_workspace(workspace_id: str = None, workspace_mets_path: str = None, **kwargs) → DBWorkspace

async ocrd_network.database.db_get_processing_job(job_id: str) → DBProcessorJob

ocrd_network.database.sync_db_get_processing_job(job_id: str) → DBProcessorJob

async ocrd_network.database.db_update_processing_job(job_id: str, **kwargs) → DBProcessorJob

ocrd_network.database.sync_db_update_processing_job(job_id: str, **kwargs) → DBProcessorJob

async ocrd_network.database.db_get_workflow_job(job_id: str) → DBWorkflowJob

ocrd_network.database.sync_db_get_workflow_job(job_id: str) → DBWorkflowJob

async ocrd_network.database.db_get_processing_jobs(job_ids: List[str]) → [<class 'ocrd_network.models.job.DBProcessorJob'>]

ocrd_network.database.sync_db_get_processing_jobs(job_ids: List[str]) → [<class 'ocrd_network.models.job.DBProcessorJob'>]