Replace pendulum with aniso8601

.github/workflows/test.yml

@@ -14,7 +14,7 @@ jobs:
     strategy:
       matrix:
         python-version:
-          - "3.12"
+          - "3.13"
     steps:
       - uses: actions/checkout@v4
       - name: Set up Python ${{ matrix.python-version }}

aggrec/aggregates.py

@@ -9,7 +9,6 @@
 from urllib.parse import urljoin
 
 import bson
-import pendulum
 import pymongo
 from bson.objectid import ObjectId
 from fastapi import APIRouter, Header, HTTPException, Request, Response, status
@@ -20,7 +19,7 @@
 from aggrec.helpers import RequestVerifier
 
 from .db_models import AggregateMetadata
-from .helpers import pendulum_as_datetime, rfc_3339_datetime_now
+from .helpers import parse_iso8601_interval, rfc_3339_datetime_now
 from .settings import Settings
 
 logger = logging.getLogger(__name__)
@@ -285,14 +284,14 @@ async def create_aggregate(
     s3_bucket = request.app.settings.s3.get_bucket_name()
 
     if aggregate_interval:
-        period = pendulum.parse(aggregate_interval)
-        if not isinstance(period, pendulum.Interval):
+        try:
+            aggregate_interval_start, aggregate_interval_timedelta = parse_iso8601_interval(aggregate_interval)
+            aggregate_interval_duration = aggregate_interval_timedelta.total_seconds()
+        except ValueError as exc:
             raise HTTPException(
                 status.HTTP_422_UNPROCESSABLE_ENTITY,
                 "Invalid Aggregate-Interval: must be an ISO 8601 time interval (e.g., '2024-01-01T12:00:00Z/PT1M')",
-            )
-        aggregate_interval_start = pendulum_as_datetime(period.start)
-        aggregate_interval_duration = period.start.diff(period.end).in_seconds()
+            ) from exc
     else:
         aggregate_interval_start = None
         aggregate_interval_duration = None

aggrec/client.py

@@ -4,12 +4,12 @@
 import json
 import logging
 import uuid
+from datetime import datetime, timezone
 from urllib.parse import urljoin
 
 import cryptography.hazmat.primitives.asymmetric.ec as ec
 import cryptography.hazmat.primitives.asymmetric.rsa as rsa
 import http_sf
-import pendulum
 import requests
 from cryptography.hazmat.primitives.asymmetric import ed25519
 from cryptography.hazmat.primitives.serialization import load_pem_private_key
@@ -48,7 +48,7 @@ def main() -> None:
 
     parser = argparse.ArgumentParser(description="Aggregate Sender")
 
-    default_interval = f"{pendulum.now().to_iso8601_string()}/PT1M"
+    default_interval = f"{datetime.now(tz=timezone.utc).isoformat()}/PT1M"
 
     parser.add_argument(
         "aggregate",
@@ -58,7 +58,7 @@ def main() -> None:
     parser.add_argument(
         "--interval",
         metavar="interval",
-        help="Aggregate interval",
+        help=f"Aggregate interval (default {default_interval})",
         default=default_interval,
     )
     parser.add_argument(

aggrec/helpers.py

@@ -1,9 +1,9 @@
 import hashlib
 import logging
-from datetime import datetime, timezone
+from datetime import datetime, timedelta, timezone
 
+import aniso8601
 import http_sf
-import pendulum
 from fastapi import HTTPException, Request, status
 from http_message_signatures import (
     HTTPMessageVerifier,
@@ -114,14 +114,6 @@ def rfc_3339_datetime_now() -> str:
     return str(datetime.now(tz=timezone.utc).strftime("%Y-%m-%dT%H:%M:%SZ"))
 
 
-def pendulum_as_datetime(dt: pendulum.DateTime) -> datetime:
-    return datetime(
-        year=dt.year,
-        month=dt.month,
-        day=dt.day,
-        hour=dt.hour,
-        minute=dt.minute,
-        second=dt.second,
-        microsecond=dt.microsecond,
-        tzinfo=dt.tzinfo,
-    )
+def parse_iso8601_interval(interval: str) -> tuple[datetime, timedelta]:
+    t1, t2 = aniso8601.parse_interval(interval)
+    return t1, timedelta(seconds=(t2 - t1).total_seconds())

pyproject.toml

@@ -21,11 +21,11 @@ pydantic-settings = "^2.7.0"
 werkzeug = "^3.0.4"
 boto3 = "^1.26.133"
 aiomqtt = "^2.2.0"
-pendulum = "^3"
 pyyaml = "^6.0.1"
 http-sf = "^1.0.2"
 redis = "^5.1.1"
 aiobotocore = ">=2.15.2"
+aniso8601 = "^10.0.0"
 
 [tool.poetry.group.dev.dependencies]
 pytest = "^8.2.0"

tests/test_iso8601.py

@@ -0,0 +1,13 @@
+from datetime import datetime, timezone
+
+from aggrec.helpers import parse_iso8601_interval
+
+
+def test_parse_iso8601_interval():
+    start, duration = parse_iso8601_interval("2025-01-15T08:56:58+00:00/PT1M")
+    assert start == datetime(year=2025, month=1, day=15, hour=8, minute=56, second=58, tzinfo=timezone.utc)
+    assert duration.total_seconds() == 60
+
+    start, duration = parse_iso8601_interval("19840101T000000Z/19840115T000000Z")
+    assert start == datetime(year=1984, month=1, day=1, hour=0, minute=0, second=0, tzinfo=timezone.utc)
+    assert duration.total_seconds() == 14 * 24 * 60 * 60