Searched refs:get_received_ts (Results 1 – 4 of 4) sorted by relevance
138 ts = await self.store.get_received_ts(event.event_id)175 ts = await self.store.get_received_ts(events[-1].event_id)
412 ts = await self.store.get_received_ts(event.event_id)441 ts = await self.store.get_received_ts(events[-1].event_id)
37 self.mock_store.get_received_ts.return_value = make_awaitable(0)
288 async def get_received_ts(self, event_id: str) -> Optional[int]: member in EventsWorkerStore