queuerPy/__init__.py at main · siherrmann/queuerPy · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
"""
QueuerPy - A Python implementation of the queuer system

A job queuing and processing system with PostgreSQL backend that provides:
- Asynchronous job processing
- Retry mechanisms with configurable policies
- Job scheduling with interval functions
- Worker management and monitoring
- Database-backed persistence
- Event-driven notifications
"""

from ._version import __version__
from uuid import UUID

__author__ = "Simon Herrmann"
__email__ = "siherrmann@users.noreply.github.com"

# Core exports
from .queuer import (
    Queuer,
    new_queuer,
    new_queuer_with_db,
)

from .helper.database import (
    DatabaseConfiguration,
)

from .model.job import (
    Job,
    JobStatus,
)

from .model.task import (
    Task,
)

from .model.batch_job import (
    BatchJob,
)

from .model.worker import (
    Worker,
    WorkerStatus,
)

from .model.master import (
    Master,
    MasterSettings,
)

from .model.options_on_error import (
    OnError,
    RetryBackoff,
)

from .helper.error import (
    QueuerError,
)

# Import submodules for direct access
from . import core
from . import database
from . import helper
from . import model

# Convenience imports for common use cases
__all__ = [
    # Core classes
    "Queuer",
    "new_queuer",
    "new_queuer_with_db",
    # Configuration
    "DatabaseConfiguration",
    # Models
    "Job",
    "JobStatus",
    "Task",
    "BatchJob",
    "Worker",
    "WorkerStatus",
    "Master",
    "MasterSettings",
    "OnError",
    "RetryBackoff",
    # Standard library types used in API
    "UUID",
    # Exceptions
    "QueuerError",
    # Submodules
    "core",
    "database",
    "helper",
    "model",
    # Version info
    "__version__",
    "__author__",
    "__email__",
]