endremborza/atqo

# flake8: noqa
"""Async Task Queue Orchestrator with Complex Resource Management"""

from .bases import ActorBase, DistAPIBase, TaskPropertyBase
from .core import Scheduler, SchedulerTask
from .distributed_apis import (
    DEFAULT_DIST_API_KEY,
    DEFAULT_MULTI_API,
    acquire_lock,
    get_lock,
)
from .exceptions import UnexpectedCapabilities
from .resource_handling import Capability, CapabilitySet
from .simplified_functions import parallel_consume, parallel_map

__version__ = "0.4.2"