Skip to main content

Backend.AI Common Package

← Back to Backend.AI Architecture

PyPI release version Supported Python versions Gitter

Overview

The Backend.AI Common package provides utilities, infrastructure, and shared components used across all Backend.AI components (Manager, Agent, Storage Proxy, Webserver, App Proxy, etc.).

Package Structure

Entry Point System

Core event-based communication and asynchronous task processing framework for Backend.AI.

  • events/ - Event Dispatcher System

    • Asynchronous event-based communication between components
    • Broadcast and Anycast event type support
    • Message queue-based event delivery
    • Event handler registration and routing
  • bgtask/ - Background Task Handler System

    • Process long-running tasks asynchronously
    • Issue Task IDs and track tasks
    • Progress monitoring and Heartbeat
    • Notify via event publishing upon completion

Infrastructure Components

Client and abstraction layer for integration with external services and systems.

  • clients/ - External service client wrappers

    • Agent client (ZeroMQ RPC)
    • Storage Proxy client (HTTP)
    • Valkey/Redis client
    • etcd client
  • message_queue/ - Message queue interface and implementation

    • Provide message publish/subscribe interface
    • Currently implemented based on Valkey/Redis streams
    • Consumer Group management
    • Future support for other message queue systems planned
  • service_discovery/ - Service registration and integration

    • etcd-based service registration and discovery
    • Provide service information for Prometheus metrics collection
    • Automatic health check and update
    • Future expansion of additional service discovery features planned
  • resilience/ - Inter-layer communication resilience patterns

    • Generalize request processing between layers
    • Retry, Timeout, Circuit Breaker
    • Automatic metric collection
    • Fallback support

Data and Types

Common structures for data exchange and type definitions between components.

  • dto/ - Data Transfer Objects (for inter-component communication)

    • Data structures used for inter-component communication
    • Request/Response models
    • Event payloads
    • Recommended to use Pydantic-based
  • types.py - Common type definitions (for internal logic)

    • Domain types used within components (SessionId, AgentId, AccessKey, etc.)
    • Shared Enum types
    • Common constants
    • Mainly used in internal business logic

Utilities

Utility modules for development convenience and common functionality.

  • metrics/ - Metrics collection and Prometheus integration

    • Metric observer pattern
    • Prometheus metric types (Counter, Gauge, Histogram)
    • HTTP metrics middleware
  • auth/ - Authentication utilities

    • Authentication between Webserver (Gateway) and Manager
    • JWT token generation/verification
    • Signature generation/verification
    • API Key management
  • web/ - Web utilities

    • HTTP helper functions
    • CORS configuration
    • Request/response processing
  • middlewares/ - Common middlewares

    • Commonly used across all components
    • Authentication middleware
    • Logging middleware
    • Error handling middleware
  • configs/ - Configuration management utilities

    • Configuration processing commonly used internally
    • Configuration file parsing (TOML, YAML)
    • Environment variable processing
    • Configuration validation

Other Components

  • contexts/ - Context management utilities

    • ContextVar-based request and user tracking
    • Current request ID tracking
    • Current user information management
    • Context propagation
  • data/ - Common data utilities

    • Data-based value processing used in internal logic
    • Data transformation and validation
    • Common data type handling
  • exception.py - Common exception classes

    • Base exceptions for all Backend.AI services
    • Exception definitions must inherit from BackendAIError
    • Domain-specific exception classes
    • Communicate error situations externally
  • utils.py - Other utility functions

    • String processing
    • Time conversion
    • Other helper functions

Installation

$ pip install backend.ai-common

For development

$ pip install -U pip setuptools
$ pip install -U -r requirements/dev.txt

Running test suite

$ python -m pytest

With the default halfstack setup, you may need to set the environment variable BACKEND_ETCD_ADDR to specify the non-standard etcd service port (e.g., localhost:8110).

The tests for common.redis module requires availability of local TCP ports 16379, 16380, 16381, 26379, 26380, and 26381 to launch a temporary Redis sentinel cluster via docker compose.

In macOS, they require a local redis-server executable to be installed, preferably via brew, because docker compose in macOS does not support host-mode networking and Redis cannot be configured to use different self IP addresses to announce to the cluster nodes and clients.

Metadata

Release files for backend.ai-common 26.4.12

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for backend.ai-common 26.4.12
File Size Uploaded
backend_ai_common-26.4.12.tar.gz 549.6 kB Details

Built distribution (wheel)

Table of built distributions (wheels) for backend.ai-common 26.4.12
File Interpreter ABI Platform
backend_ai_common-26.4.12-py3-none-any.whl Python 3 none any Details

Total release size: 1.4 MB

Release files / backend_ai_common-26.4.12.tar.gz

Download URL backend_ai_common-26.4.12.tar.gz
Size 549.6 kB
Tags Source
SHA-256 checksum
How to use checksums
eae0df24bc00d29fe9cd3e9034211f04836f13d2b1d12c5aa60af1dde4608266
BLAKE2b-256 checksum
How to use checksums
bafd169e4486d320948140971ca728cf43a89fd2db871650970f83fe420663ce
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
Yes
Uploaded via twine/6.2.0 CPython/3.13.7

Release files / backend_ai_common-26.4.12-py3-none-any.whl

Download URL backend_ai_common-26.4.12-py3-none-any.whl
Size 850.5 kB
Tags Python 3
SHA-256 checksum
How to use checksums
b4d5ce2412f2a322be023104fee8669625e583ddb796813922e3456b003491de
BLAKE2b-256 checksum
How to use checksums
bd6591376b6646a64b6c80628a07006047c7979961aca0719eda3c59eb59ef47
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
Yes
Uploaded via twine/6.2.0 CPython/3.13.7

Release history Release notifications | RSS feed

26.9.5

2 release files

26.9.4

2 release files

26.9.3

2 release files

26.9.2

2 release files

26.8.1

2 release files

26.8.0

2 release files

This release

26.4.12 This release

2 release files

26.4.9

2 release files

26.4.8

2 release files

26.4.6

2 release files

26.4.5

2 release files

26.4.4

2 release files

26.4.3

2 release files

26.4.2

2 release files

26.4.1

2 release files

26.3.3

2 release files

26.3.2

2 release files

26.3.1

2 release files

26.3.0

2 release files

26.2.5

2 release files

26.2.4

2 release files

26.2.3

2 release files

26.2.2

2 release files

26.2.1

2 release files

26.2.0

2 release files

26.1.0

2 release files

25.8.1

2 release files

25.8.0

2 release files

25.7.0

2 release files

25.6.7

2 release files

25.6.6

2 release files

25.6.4

2 release files

25.6.3

2 release files

25.6.2

2 release files

25.6.1

2 release files

25.6.0

2 release files

25.5.2

2 release files

25.5.1

2 release files

25.5.0

2 release files

25.4.0

2 release files

25.3.3

2 release files

25.3.2

2 release files

25.3.1

2 release files

25.3.0

2 release files

25.1.1

2 release files

24.12.0

1 release file

24.9.7

2 release files

24.9.4

2 release files

24.9.2

2 release files

24.9.1

2 release files

24.9.0

2 release files

24.3.9

2 release files

24.3.8

2 release files

24.3.6

2 release files

24.3.5

2 release files

24.3.3

2 release files

24.3.2

2 release files

23.9.8

2 release files

23.9.6

2 release files

23.9.3

2 release files

23.9.2

2 release files

23.9.1

2 release files

23.9.0

2 release files

23.3.9

2 release files

23.3.6

2 release files

23.3.5

2 release files

23.3.4

2 release files

23.3.3

2 release files

23.3.0

2 release files

22.9.9

2 release files

22.9.8

2 release files

22.9.5

2 release files

22.9.4

2 release files

22.9.3

2 release files

22.9.2

2 release files

22.9.0

2 release files

22.3.9

2 release files

22.3.8

2 release files

22.3.7

2 release files

22.3.6

2 release files

22.3.1

2 release files

22.3.0

2 release files

21.9.8

2 release files

21.9.6

2 release files

21.9.5

2 release files

21.9.4

2 release files

21.9.3

2 release files

21.9.2

2 release files

21.9.1

2 release files

21.3.9

2 release files

21.3.8

2 release files

21.3.7

2 release files

21.3.5

2 release files

21.3.4

2 release files

21.3.2

2 release files

21.3.1

2 release files

21.3.0

2 release files

20.9.9

2 release files

20.9.8

2 release files

20.9.7

2 release files

20.9.6

2 release files

20.9.5

2 release files

20.9.4

2 release files

20.9.2

2 release files

20.9.1

2 release files

20.9.0

2 release files

20.3.9

2 release files

20.3.7

2 release files

20.3.6

2 release files

20.3.5

2 release files

20.3.4

2 release files

20.3.2

2 release files

20.3.1

2 release files

20.3.0

2 release files

19.9.9

2 release files

19.9.5

2 release files

19.9.4

2 release files

19.9.3

2 release files

19.9.1

2 release files

19.3.2

2 release files

19.3.1

2 release files

1.4.1

2 release files

1.4.0

2 release files

1.3.1

2 release files

1.3.0

2 release files

1.2.0

2 release files

1.1.2

2 release files

1.1.0

2 release files

1.0.3

2 release files

1.0.2

2 release files

1.0.0

2 release files

Anthropic, PBC Visionary sponsor Bloomberg Visionary sponsor Hudson River Trading Visionary sponsor Meta Visionary sponsor NVIDIA Visionary sponsor Microsoft Sustainability sponsor Depot Continuous Integration AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page