aria

The ARIA root package provides entry points for extension and storage initialization.

aria.workflow(func=None, suffix_template=”)

Workflow decorator.

aria.operation(func=None, toolbelt=False, suffix_template=”, logging_handlers=None)

Operation decorator.

aria.install_aria_extensions()

Iterates all Python packages with names beginning with aria_extension_ and all aria_extension entry points and loads them.

It then invokes all registered extension functions.

aria.application_model_storage(api, api_kwargs=None, initiator=None, initiator_kwargs=None)

Initiate model storage.

aria.application_resource_storage(api, api_kwargs=None, initiator=None, initiator_kwargs=None)

Initiate resource storage.

aria.core

ARIA core module.

class aria.core.Core(model_storage, resource_storage, plugin_manager)

Bases: object

create_service(service_template_id, inputs, service_name=None)
create_service_template(service_template_path, service_template_dir, service_template_name)
delete_service(service_id, force=False)
delete_service_template(service_template_id)
model_storage
plugin_manager
resource_storage
validate_service_template(service_template_path)

aria.exceptions

Base exception classes and other common exceptions used throughout ARIA.

exception aria.exceptions.AriaError

Bases: exceptions.Exception

Base class for ARIA errors.

exception aria.exceptions.AriaException(message=None, cause=None, cause_traceback=None)

Bases: exceptions.Exception

Base class for ARIA exceptions.

exception aria.exceptions.DependentActiveExecutionsError

Bases: aria.exceptions.AriaError

Raised when attempting to delete a service which has active executions.

exception aria.exceptions.DependentAvailableNodesError

Bases: aria.exceptions.AriaError

Raised when attempting to delete a service which has available nodes.

exception aria.exceptions.DependentServicesError

Bases: aria.exceptions.AriaError

Raised when attempting to delete a service template which has existing services.

exception aria.exceptions.InstantiationError

Bases: aria.exceptions.AriaError

exception aria.exceptions.ParsingError

Bases: aria.exceptions.AriaError

aria.extension

Mechanism for registering and loading ARIA extensions.

aria.extension.init()

Initialize all registrars by calling all registered functions.

aria.logger

Mix-ins and functions for logging, supporting multiple backends (such as SQL) and consistent formatting.

class aria.logger.LoggerMixin(*args, **kwargs)

Bases: object

Provides logging functionality to a class.

Variables:
  • logger_name – logger name; default to the class name
  • logger_level – logger level; defaults to logging.DEBUG
  • base_logger – child loggers are created from this; defaults to the root logger
logger_level = 10
logger_name = None
classmethod with_logger(logger_name=None, logger_level=10, base_logger=<logging.RootLogger object>, **kwargs)

Set the logger used by the consuming class.

aria.logger.create_console_log_handler(level=10, formatter=None)
Parameters:
  • level –
  • formatter –
aria.logger.create_file_log_handler(file_path, level=10, max_bytes=5120000, backup_count=10, formatter=None)

Create a logging.handlers.RotatingFileHandler.

aria.logger.create_logger(logger=<logging.Logger object>, handlers=(), **configs)
Parameters:
  • logger (logging.Logger) – logger name; defaults to ARIA logger
  • handlers ([]) – logger handlers
  • configs ([]) – logger configurations
Returns:

logger
aria.logger.create_sqla_log_handler(model, log_cls, execution_id, level=10)