ocrd_network

• ocrd_network package
  • Subpackages
    • ocrd_network.cli package
      • Submodules
    • ocrd_network.models package
      • DBProcessorJob
      • DBWorkflowJob
      • DBWorkspace
      • DBWorkflowScript
      • PYJobInput
      • PYJobOutput
      • PYOcrdTool
      • PYResultMessage
      • PYWorkflowJobOutput
      • Submodules
    • ocrd_network.rabbitmq_utils package
      • check_if_queue_exists()
      • connect_rabbitmq_consumer()
      • connect_rabbitmq_publisher()
      • create_message_queues()
      • verify_and_parse_mq_uri()
      • verify_rabbitmq_available()
      • RMQConsumer
      • RMQConnector
      • RMQPublisher
      • OcrdProcessingMessage
      • OcrdResultMessage
      • Submodules
    • ocrd_network.runtime_data package
      • Deployer
      • DataHost
      • DataMongoDB
      • DataNetworkAgent
      • DataRabbitMQ
      • DataProcessingWorker
      • DataProcessorServer
      • Submodules
  • Submodules
    • ocrd_network.client module
      • Client
    • ocrd_network.client_utils module
      • poll_job_status_till_timeout_fail_or_success()
      • poll_wf_status_till_timeout_fail_or_success()
      • get_ps_deployed_processors()
      • get_ps_deployed_processor_ocrd_tool()
      • get_ps_processing_job_log()
      • get_ps_processing_job_status()
      • get_ps_workflow_job_status()
      • post_ps_processing_request()
      • post_ps_workflow_request()
      • verify_server_protocol()
    • ocrd_network.constants module
      • AgentType
      • DeployType
      • JobState
      • NetworkLoggingDirs
      • ServerApiTags
    • ocrd_network.database module
      • initiate_database()
      • sync_initiate_database()
      • db_create_workspace()
      • sync_db_create_workspace()
      • db_get_workspace()
      • sync_db_get_workspace()
      • db_update_workspace()
      • sync_db_update_workspace()
      • db_create_processing_job()
      • sync_db_create_processing_job()
      • db_get_processing_job()
      • sync_db_get_processing_job()
      • db_update_processing_job()
      • sync_db_update_processing_job()
      • db_create_workflow_job()
      • sync_db_create_workflow_job()
      • db_get_workflow_job()
      • sync_db_get_workflow_job()
      • db_get_processing_jobs()
      • sync_db_get_processing_jobs()
      • db_create_workflow_script()
      • sync_db_create_workflow_script()
      • db_get_workflow_script()
      • sync_db_get_workflow_script()
      • db_find_first_workflow_script_by_content()
      • sync_db_find_first_workflow_script_by_content()
      • verify_database_uri()
      • verify_mongodb_available()
    • ocrd_network.logging_utils module
      • configure_file_handler_with_formatter()
      • get_root_logging_dir()
      • get_cache_locked_pages_logging_file_path()
      • get_cache_processing_requests_logging_file_path()
      • get_mets_server_logging_file_path()
      • get_processing_job_logging_file_path()
      • get_processing_server_logging_file_path()
      • get_processing_worker_logging_file_path()
      • get_processor_server_logging_file_path()
    • ocrd_network.param_validators module
      • ServerAddressParamType
      • QueueServerParamType
      • DatabaseParamType
    • ocrd_network.process_helpers module
      • invoke_processor()
    • ocrd_network.processing_server module
      • ProcessingServer
    • ocrd_network.processing_worker module
      • ProcessingWorker
    • ocrd_network.processor_server module
      • ProcessorServer
    • ocrd_network.server_cache module
      • CacheLockedPages
      • CacheProcessingRequests
    • ocrd_network.server_utils module
      • create_processing_message()
      • create_workspace_if_not_exists()
      • get_from_database_workflow_job()
      • get_from_database_workspace()
      • get_page_ids_list()
      • request_processor_server_tool_json()
      • forward_job_to_processor_server()
      • get_workflow_content()
      • validate_and_return_mets_path()
      • parse_workflow_tasks()
      • raise_http_exception()
      • validate_job_input()
      • validate_workflow()
      • validate_first_task_input_file_groups_existence()
      • kill_mets_server_zombies()
    • ocrd_network.tcp_to_uds_mets_proxy module
      • MetsServerProxy
    • ocrd_network.utils module
      • call_sync()
      • calculate_execution_time()
      • calculate_processing_request_timeout()
      • convert_url_to_uds_format()
      • expand_page_ids()
      • generate_created_time()
      • generate_id()
      • generate_workflow_content()
      • generate_workflow_content_hash()
      • is_url_responsive()
      • load_ocrd_all_tool_json()
      • post_to_callback_url()
      • get_ocrd_workspace_instance()
      • get_ocrd_workspace_physical_pages()
      • is_mets_server_running()
      • stop_mets_server()
      • get_uds_path()