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, encode_type: str = 'utf-8') → bytes

static decode_yml(ocrd_processing_message: bytes, decode_type: str = 'utf-8') → OcrdProcessingMessage

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

Bases: object

static encode_yml(ocrd_result_message: OcrdResultMessage, encode_type: str = 'utf-8') → bytes

static decode_yml(ocrd_result_message: bytes, decode_type: str = 'utf-8') → OcrdResultMessage