Feature/monitoring times

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "omniq"
-version = "2.0.0"
+version = "3.0.0"
 authors = [
   { name="Not Empty Foundation", email="dev@not-empty.org" },
 ]

src/omniq/__init__.py

@@ -1,3 +1,12 @@
 from .client import OmniqClient
 from .consumer import consume
+from .monitor import QueueMonitor
 from .types import JobCtx, PayloadT
+
+__all__ = [
+    "OmniqClient",
+    "QueueMonitor",
+    "consume",
+    "JobCtx",
+    "PayloadT",
+]

src/omniq/_ops.py

@@ -7,7 +7,7 @@
 
 from .clock import now_ms
 from .ids import new_ulid
-from .types import ReservePaused, ReserveJob, ReserveResult, AckFailResult, BatchRemoveResult, BatchRetryFailedResult
+from .types import ReservePaused, ReserveJob, ReserveResult, AckFailResult, BatchRemoveResult, BatchRetryFailedResult, BatchResultItem
 from .transport import RedisLike
 from .scripts import OmniqScripts
 from .helper import queue_base, queue_anchor, childs_anchor
@@ -373,7 +373,7 @@ def retry_failed_batch(
                 i += 3
             else:
                 i += 2
-            out.append((job_id, status, reason))
+            out.append(BatchResultItem(job_id=job_id, status=status, reason=reason))
         return out
 
     def remove_job(self, *, queue: str, job_id: str, lane: str) -> str:
@@ -442,7 +442,7 @@ def remove_jobs_batch(
                 i += 3
             else:
                 i += 2
-            out.append((job_id, status, reason))
+            out.append(BatchResultItem(job_id=job_id, status=status, reason=reason))
         return out
 
     def childs_init(self, *, key: str, expected: int) -> None: