From 3b68f49f042efd4b7ae6df7c462d8014e526e1e5 Mon Sep 17 00:00:00 2001 From: m5l14i11 Date: Sat, 27 Apr 2024 03:06:57 +0300 Subject: [PATCH] upd --- position/_actor.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/position/_actor.py b/position/_actor.py index 66aa83d4..9352cfec 100644 --- a/position/_actor.py +++ b/position/_actor.py @@ -1,5 +1,6 @@ import asyncio import logging +import time from typing import Union from core.actors import Actor @@ -87,7 +88,9 @@ async def on_receive(self, event): ) async def handle_signal_received(self, event: SignalEvent) -> bool: - logger.info(f"Signal Received: {event}") + if int(event.meta.timestamp) < int(time.time()) - 3: + logger.warn(f"Stale Signal: {event}, {time.time()}") + return False async def create_and_store_position(event: SignalEvent): position = await self.position_factory.create_position(