Source code for ocrd_network.constants

from enum import Enum

DOCKER_IMAGE_MONGO_DB = "mongo"
DOCKER_IMAGE_RABBIT_MQ = "rabbitmq:4.2-management"

NETWORK_PROTOCOLS = ["http://", "https://"]
OCRD_ALL_TOOL_JSON = "ocrd-all-tool.json"
# Used as a placeholder to lock all pages when no page_id is specified
SERVER_ALL_PAGES_PLACEHOLDER = "all_pages"

# TODO: Make this more configurable
RESOURCE_MANAGER_SERVER_PORT = 45555



[docs]
class StrEnum(str, Enum):
    def __str__(self):
        return self.value






[docs]
class DeployType(StrEnum):
    # Deployed by the Processing Server config file
    DOCKER = "docker"
    NATIVE = "native"
    # Deployed through a registration endpoint of the Processing Server
    # TODO: That endpoint is still not implemented
    EXTERNAL = "external"




# TODO: Make the states uppercase


[docs]
class JobState(StrEnum):
    # The processing job is cached inside the Processing Server requests cache
    cached = "CACHED"
    # The processing job was cancelled due to failed dependencies
    cancelled = "CANCELLED"
    # Processing job failed
    failed = "FAILED"
    # The processing job is queued inside the RabbitMQ
    queued = "QUEUED"
    # Processing job is currently running on a Worker
    running = "RUNNING"
    # Processing job finished successfully
    success = "SUCCESS"
    # Processing job has not been assigned yet
    unset = "UNSET"






[docs]
class NetworkLoggingDirs(StrEnum):
    METS_SERVERS = "mets_servers"
    PROCESSING_JOBS = "processing_jobs"
    PROCESSING_SERVERS = "processing_servers"
    PROCESSING_WORKERS = "processing_workers"
    RESOURCE_MANAGER_SERVERS = "resource_manager_servers"






[docs]
class ServerApiTags(StrEnum):
    ADMIN = "admin"
    DISCOVERY = "discovery"
    PROCESSING = "processing"
    TOOLS = "tools"
    WORKFLOW = "workflow"
    WORKSPACE = "workspace"