minor fixes

Author: agam1092005

state-manager/app/models/db/state.py

@@ -30,7 +30,6 @@ class State(BaseDatabaseModel):
     manual_retry_fanout_id: str = Field(default="", description="Fanout ID from a manual retry request, ensuring unique retries for unite nodes.")
     queued_at: Optional[int] = Field(None, description="Unix time in milliseconds when state was queued")
     timeout_minutes: Optional[int] = Field(None, gt=0, description="Timeout in minutes for this specific state, taken from node registration")
-    queued_at: Optional[int] = Field(None, description="Unix time in milliseconds when the state was queued")
 
     @before_event([Insert, Replace, Save])
     def _generate_fingerprint(self):

state-manager/app/tasks/check_node_timeout.py

@@ -1,4 +1,5 @@
 import time
+from beanie.operators import Ne
 from app.models.db.state import State
 from app.models.state_status_enum import StateStatusEnum
 from app.singletons.logs_manager import LogsManager
@@ -17,7 +18,7 @@ async def check_node_timeout():
         # Find all QUEUED states with queued_at set
         queued_states = await State.find(
             State.status == StateStatusEnum.QUEUED,
-            State.queued_at != None
+            Ne(State.queued_at, None)
         ).to_list()
 
         states_to_timeout = []