+
+ +
+

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)
+
+ +
+
+ + +
+
+ +
+