Index

A

add_item() (session.DataCache.DataCache method) (session.TaskSession.TaskSession method) additional_parameters (pydantic_models.AlgorithmRegisteredResponse attribute) (pydantic_models.ExecutionRecord attribute) (pydantic_models.IncomingExecutionRequest attribute) address (pydantic_models.MinioServer attribute) (pydantic_models.MinioServerInfo attribute) Algorithm (class in pydantic_models) algorithm_cache() (in module server_utils) algorithm_description (pydantic_models.AlgorithmRegisteredResponse attribute) algorithm_id (pydantic_models.AlgorithmRegisteredResponse attribute) (pydantic_models.ExecutionRecord attribute) (pydantic_models.IncomingExecutionRequest attribute) algorithm_input_queue (pydantic_models.AlgorithmRegisteredResponse attribute) algorithm_key (pydantic_models.S3ModelFileRecord attribute) algorithm_major_version (pydantic_models.Algorithm attribute) (pydantic_models.S3ModelFile attribute) algorithm_minor_version (pydantic_models.AlgorithmRegisteredResponse attribute) (pydantic_models.S3ModelFile attribute)

algorithm_name (pydantic_models.Algorithm attribute) (pydantic_models.AlgorithmRegisteredResponse attribute) (pydantic_models.FailedAlgorithmRegisteredResponse attribute) (pydantic_models.S3ModelFile attribute) algorithm_path (pydantic_models.S3ModelFile attribute) algorithm_tags (pydantic_models.AlgorithmRegisteredResponse attribute) algorithm_type (pydantic_models.AlgorithmRegisteredResponse attribute) algorithm_utils.AlgorithmDeployer module algorithm_utils.AlgorithmManager module algorithm_utils.BaseRunner module algorithm_version (pydantic_models.AlgorithmRegisteredResponse attribute) (pydantic_models.FailedAlgorithmRegisteredResponse attribute) AlgorithmDeployer (class in algorithm_utils.AlgorithmDeployer) AlgorithmManager (class in algorithm_utils.AlgorithmManager) AlgorithmRegisteredResponse (class in pydantic_models)

B

BaseConnection (class in database_connection.BaseConnection)

BaseRunner (class in algorithm_utils.BaseRunner) bucket_name (pydantic_models.S3Bucket attribute)

C

calculate_etag() (algorithm_utils.AlgorithmDeployer.AlgorithmDeployer static method) (in module database_connection.database_utils) calculate_etag_multipart() (in module database_connection.database_utils) calculate_s3_etag() (in module server_utils) check_and_create_database_collections() (in module server_utils) check_collections_exists() (database_connection.BaseConnection.BaseConnection method) (database_connection.S3Connection.S3Connection method) (database_connection.TempfileConnection.TempfileConnection method) check_if_zip_is_importable() (algorithm_utils.AlgorithmDeployer.AlgorithmDeployer static method) check_mps_availability() (in module server_utils) check_objects_exist() (database_connection.BaseConnection.BaseConnection method) (database_connection.S3Connection.S3Connection method) (database_connection.TempfileConnection.TempfileConnection method)

check_system_gpu_availability() (in module server_utils) check_torch_with_cuda_available() (in module server_utils) clear() (session.DataCache.DataCache method) clear_cache() (session.TaskSession.TaskSession method) console_address (pydantic_models.MinioServer attribute) (pydantic_models.MinioServerInfo attribute) create_collections() (database_connection.BaseConnection.BaseConnection method) (database_connection.S3Connection.S3Connection method) (database_connection.TempfileConnection.TempfileConnection method) cuda_available (pydantic_models.RootMessage attribute) cuda_capable_devices_count (pydantic_models.RootMessage attribute)

D

data_cache() (in module server_utils) data_caches (session.TaskSession.TaskSession attribute) database_connection.BaseConnection module database_connection.database_utils module database_connection.S3Connection module database_connection.TempfileConnection module DataCache (class in session.DataCache) DebuggingTaskHandler (class in tasks.DebuggingTaskHandler)

default_device (pydantic_models.AlgorithmRegisteredResponse attribute) delete_algorithms() (algorithm_utils.AlgorithmManager.AlgorithmManager method) delete_collections() (database_connection.BaseConnection.BaseConnection method) (database_connection.S3Connection.S3Connection method) (database_connection.TempfileConnection.TempfileConnection method) delete_dataset() (in module routers.file_controller) delete_objects() (database_connection.BaseConnection.BaseConnection method) (database_connection.S3Connection.S3Connection method) (database_connection.TempfileConnection.TempfileConnection method) detail (pydantic_models.ResponseMessage attribute) device (algorithm_utils.BaseRunner.BaseRunner property) domain (pydantic_models.RootMessage attribute) download_dataset() (in module routers.file_controller)

E

executable_path (pydantic_models.MinioServer attribute) execute_algorithm() (in module routers.execution_controller) execution_device_override (pydantic_models.ExecutionRecord attribute) (pydantic_models.IncomingExecutionRequest attribute)

execution_id (pydantic_models.ExecutionRecord attribute) (pydantic_models.ExecutionResponse attribute) ExecutionLogRecord (class in pydantic_models) ExecutionRecord (class in pydantic_models) ExecutionResponse (class in pydantic_models)

F

FailedAlgorithmRegisteredResponse (class in pydantic_models) fetch_algorithm() (tasks.DebuggingTaskHandler.DebuggingTaskHandler method) (tasks.TaskHandler.TaskHandler method) fetch_asset() (algorithm_utils.BaseRunner.BaseRunner method) (tasks.DebuggingTaskHandler.DebuggingTaskHandler method) (tasks.TaskHandler.TaskHandler method) fetch_data() (algorithm_utils.BaseRunner.BaseRunner method) (tasks.TaskHandler.TaskHandler method)

file_body (pydantic_models.FileUploadBody attribute) file_id (pydantic_models.FileUploadResponse attribute) FileUploadBody (class in pydantic_models) FileUploadResponse (class in pydantic_models) find_algorithm_by_id() (in module server_utils) find_other_than_py_files() (algorithm_utils.AlgorithmDeployer.AlgorithmDeployer static method) find_py_files() (algorithm_utils.AlgorithmDeployer.AlgorithmDeployer static method)

G

generate_presigned_url() (database_connection.S3Connection.S3Connection method) generate_uuid() (algorithm_utils.AlgorithmDeployer.AlgorithmDeployer static method) (in module server_utils) get_algorithm() (in module routers.algorithms_controller) get_execution_record() (in module routers.execution_controller) get_objects() (database_connection.BaseConnection.BaseConnection method) (database_connection.S3Connection.S3Connection method) (database_connection.TempfileConnection.TempfileConnection method)

get_presigned_download_url() (database_connection.S3Connection.S3Connection method) get_presigned_upload_url() (database_connection.S3Connection.S3Connection method) get_subprocess_fn() (in module server_utils) group (pydantic_models.RootMessage attribute)

H

hash_directory() (algorithm_utils.AlgorithmDeployer.AlgorithmDeployer static method)

hash_py_file() (algorithm_utils.AlgorithmDeployer.AlgorithmDeployer static method)

I

IncomingExecutionRequest (class in pydantic_models) inference() (algorithm_utils.BaseRunner.BaseRunner method) inference_base() (algorithm_utils.BaseRunner.BaseRunner method)

initialize() (algorithm_utils.BaseRunner.BaseRunner method) input_dataset_ids (pydantic_models.ExecutionRecord attribute) (pydantic_models.IncomingExecutionRequest attribute)

L

list_algorithms() (algorithm_utils.AlgorithmManager.AlgorithmManager method) list_collections() (database_connection.BaseConnection.BaseConnection method) (database_connection.S3Connection.S3Connection method) (database_connection.TempfileConnection.TempfileConnection method) list_model_files() (in module routers.algorithms_controller) list_objects() (database_connection.BaseConnection.BaseConnection method) (database_connection.S3Connection.S3Connection method) (database_connection.TempfileConnection.TempfileConnection method)

load_assets() (algorithm_utils.BaseRunner.BaseRunner method) load_item_from_session() (algorithm_utils.BaseRunner.BaseRunner method) (tasks.TaskHandler.TaskHandler method) log (pydantic_models.ExecutionLogRecord attribute) (pydantic_models.ExecutionRecord attribute) log_message() (algorithm_utils.BaseRunner.BaseRunner method)

M

mark_as_completed() (tasks.TaskHandler.TaskHandler method) mark_as_failed() (tasks.TaskHandler.TaskHandler method) message (pydantic_models.FailedAlgorithmRegisteredResponse attribute) MinioServer (class in pydantic_models) MinioServerInfo (class in pydantic_models) model_config (pydantic_models.Algorithm attribute) (pydantic_models.AlgorithmRegisteredResponse attribute) (pydantic_models.ExecutionLogRecord attribute) (pydantic_models.ExecutionRecord attribute) (pydantic_models.ExecutionResponse attribute) (pydantic_models.FailedAlgorithmRegisteredResponse attribute) (pydantic_models.FileUploadBody attribute) (pydantic_models.FileUploadResponse attribute) (pydantic_models.IncomingExecutionRequest attribute) (pydantic_models.MinioServer attribute) (pydantic_models.MinioServerInfo attribute) (pydantic_models.ResponseMessage attribute) (pydantic_models.RootMessage attribute) (pydantic_models.S3Bucket attribute) (pydantic_models.S3ModelFile attribute) (pydantic_models.S3ModelFileRecord attribute) (pydantic_models.UrlResponse attribute)

module algorithm_utils.AlgorithmDeployer algorithm_utils.AlgorithmManager algorithm_utils.BaseRunner database_connection.BaseConnection database_connection.database_utils database_connection.S3Connection database_connection.TempfileConnection pydantic_models routers.algorithms_controller routers.execution_controller routers.file_controller server_utils session.DataCache session.TaskSession tasks.DebuggingTaskHandler tasks.TaskHandler

N

name (pydantic_models.RootMessage attribute)

O

organization (pydantic_models.RootMessage attribute)

output_dataset_ids (pydantic_models.ExecutionRecord attribute) (tasks.TaskHandler.TaskHandler property)

P

parse_pyproject_toml() (algorithm_utils.AlgorithmDeployer.AlgorithmDeployer method) post_data() (algorithm_utils.BaseRunner.BaseRunner method) (tasks.TaskHandler.TaskHandler method) postprocess() (algorithm_utils.BaseRunner.BaseRunner method) postprocess_base() (algorithm_utils.BaseRunner.BaseRunner method) preprocess() (algorithm_utils.BaseRunner.BaseRunner method) preprocess_base() (algorithm_utils.BaseRunner.BaseRunner method) process_path_to_dict_key() (algorithm_utils.AlgorithmDeployer.AlgorithmDeployer static method) progress (pydantic_models.ExecutionRecord attribute) (tasks.TaskHandler.TaskHandler property)

put_objects() (database_connection.BaseConnection.BaseConnection method) (database_connection.S3Connection.S3Connection method) (database_connection.TempfileConnection.TempfileConnection method) put_objects_with_duplicity_check() (database_connection.BaseConnection.BaseConnection method) (database_connection.S3Connection.S3Connection method) (database_connection.TempfileConnection.TempfileConnection method) pydantic_models module

R

remove_item() (session.DataCache.DataCache method) (session.TaskSession.TaskSession method) remove_item_from_session() (algorithm_utils.BaseRunner.BaseRunner method) (tasks.TaskHandler.TaskHandler method) ResponseMessage (class in pydantic_models) RootMessage (class in pydantic_models) routers.algorithms_controller module

routers.execution_controller module routers.file_controller module run() (algorithm_utils.BaseRunner.BaseRunner method) runner_context (algorithm_utils.BaseRunner.BaseRunner property) runner_path (pydantic_models.S3ModelFile attribute)

S

S3Bucket (class in pydantic_models) S3Connection (class in database_connection.S3Connection) S3FileUploader (class in database_connection.database_utils) S3ModelFile (class in pydantic_models) S3ModelFileRecord (class in pydantic_models) save_item_to_session() (algorithm_utils.BaseRunner.BaseRunner method) (tasks.TaskHandler.TaskHandler method) server_utils module session.DataCache module session.TaskSession module

session_token (pydantic_models.ExecutionRecord attribute) (pydantic_models.IncomingExecutionRequest attribute) (session.TaskSession.TaskSession property) (tasks.TaskHandler.TaskHandler property) set_as_current_task_handler() (tasks.TaskHandler.TaskHandler method) set_progress() (algorithm_utils.BaseRunner.BaseRunner method) status (pydantic_models.ExecutionRecord attribute) (tasks.TaskHandler.TaskHandler property) storage_path (pydantic_models.MinioServer attribute) (pydantic_models.MinioServerInfo attribute) store_algorithm() (algorithm_utils.AlgorithmDeployer.AlgorithmDeployer method) supported_devices (pydantic_models.AlgorithmRegisteredResponse attribute)

T

tags (pydantic_models.RootMessage attribute) task_handler (algorithm_utils.BaseRunner.BaseRunner property) task_id (tasks.TaskHandler.TaskHandler property) TaskHandler (class in tasks.TaskHandler) tasks.DebuggingTaskHandler module

tasks.TaskHandler module TaskSession (class in session.TaskSession) TempfileConnection (class in database_connection.TempfileConnection) time_completed (pydantic_models.ExecutionRecord attribute) (tasks.TaskHandler.TaskHandler property) time_started (pydantic_models.ExecutionRecord attribute)

U

update_log() (tasks.TaskHandler.TaskHandler method) upload_dataset() (in module routers.file_controller) upload_file_multipart() (database_connection.database_utils.S3FileUploader method)

upload_part() (database_connection.database_utils.S3FileUploader method) url (pydantic_models.UrlResponse attribute) UrlResponse (class in pydantic_models)

V

version (pydantic_models.RootMessage attribute)

W

weak_lru() (in module server_utils)