ocrd_network.rabbitmq_utils.ocrd_messages module

class ocrd_network.rabbitmq_utils.ocrd_messages.OcrdProcessingMessage(job_id: str, processor_name: str, created_time: int, input_file_grps: List[str], output_file_grps: List[str] | None, path_to_mets: str | None, workspace_id: str | None, page_id: str | None, result_queue_name: str | None, callback_url: str | None, internal_callback_url: str | None, parameters: Dict[str, Any] | None = None)

Bases: object

static encode_yml(ocrd_processing_message: OcrdProcessingMessage) → bytes

static decode_yml(ocrd_processing_message: bytes) → OcrdProcessingMessage

class ocrd_network.rabbitmq_utils.ocrd_messages.OcrdResultMessage(job_id: str, state: str, path_to_mets: str | None = None, workspace_id: str | None = None)

Bases: object

static encode_yml(ocrd_result_message: OcrdResultMessage) → bytes

static decode_yml(ocrd_result_message: bytes) → OcrdResultMessage