diff options
| author | Max Nanis | 2026-08-21 17:19:41 -0700 |
|---|---|---|
| committer | Max Nanis | 2026-08-21 17:19:41 -0700 |
| commit | 6cf7ccbaa8306700e64ada19d6f99807743b2865 (patch) | |
| tree | 16ccde36ba2694b8c03bf8bdcee9cfcb2909046a /tests/managers/test_events.py | |
| parent | 352520a2bd4ac066e90587e44d8b818043407917 (diff) | |
| download | generalresearch-6cf7ccbaa8306700e64ada19d6f99807743b2865.tar.gz generalresearch-6cf7ccbaa8306700e64ada19d6f99807743b2865.zip | |
Ruff auto updates to 3.14
Diffstat (limited to 'tests/managers/test_events.py')
| -rw-r--r-- | tests/managers/test_events.py | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/tests/managers/test_events.py b/tests/managers/test_events.py index a0fab38..6941c00 100644 --- a/tests/managers/test_events.py +++ b/tests/managers/test_events.py @@ -1,22 +1,22 @@ +import math import random import time -from datetime import timedelta, datetime, timezone +from datetime import UTC, datetime, timedelta, timezone from decimal import Decimal from functools import partial +from math import floor from typing import Optional from uuid import uuid4 -import math import pytest -from math import floor from generalresearch.managers.events import EventSubscriber from generalresearch.models import Source from generalresearch.models.events import ( - MessageKind, - EventType, AggregateBySource, + EventType, MaxGaugeBySource, + MessageKind, ) from generalresearch.models.legacy.bucket import Bucket from generalresearch.models.thl.definitions import Status, StatusCode1 @@ -41,13 +41,13 @@ def event_subscriber(thl_redis_config, product_id): def create_dummy( - product_id: Optional[str] = None, product_user_id: Optional[str] = None + product_id: str | None = None, product_user_id: str | None = None ) -> User: return User( product_id=product_id, product_user_id=product_user_id or uuid4().hex, uuid=uuid4().hex, - created=datetime.now(tz=timezone.utc), + created=datetime.now(tz=UTC), user_id=random.randint(0, floor(2**32 / 2)), ) @@ -496,7 +496,7 @@ class TestChannelsSubscriptions: wall.update( status=Status.COMPLETE, status_code_1=StatusCode1.COMPLETE, - finished=datetime.now(tz=timezone.utc), + finished=datetime.now(tz=UTC), cpi=Decimal("1"), ) event_manager.handle_task_finish(wall, session, user) |
