diff options
| -rw-r--r-- | generalresearch/managers/events.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/generalresearch/managers/events.py b/generalresearch/managers/events.py index 4a2afb2..85c451b 100644 --- a/generalresearch/managers/events.py +++ b/generalresearch/managers/events.py @@ -1,5 +1,6 @@ from __future__ import annotations +import logging import math import socket import threading @@ -10,7 +11,6 @@ from typing import TYPE_CHECKING, Any from redis.client import PubSub, Redis -from generalresearch.incite.base import LOG from generalresearch.managers.base import RedisManager from generalresearch.models.custom_types import UUIDStr from generalresearch.models.definitions import Source @@ -40,6 +40,8 @@ if TYPE_CHECKING: else: InfluxDBClient = object +LOG = logging.getLogger(__name__) + # Sums all the values in a single hashmap SUM_HASH_LUA_SCRIPT = """ local vals = redis.call("HVALS", KEYS[1]) @@ -218,7 +220,6 @@ class UserStatsManager(RedisManager): class TaskStatsManager(RedisManager): - def __init__(self, *args, **kwargs): super().__init__(*args, **kwargs) @@ -595,7 +596,6 @@ class SessionStatsManager(RedisManager): class StatsManager(UserStatsManager, SessionStatsManager, TaskStatsManager): - def get_stats_message(self, product_id: UUIDStr) -> StatsMessage: res = self.get_session_stats(product_id=product_id) res.update(self.get_user_stats(product_id=product_id)) |