fixup

prog/communication.py

@@ -225,7 +225,7 @@ class DownloadServer(FuncCaller):
                             await worker(dt)
 
     @server_exec()
-    async def list_realtime_data(self, dt_from: datetime):
+    async def list_realtime_data(self, dt_from: datetime, dt_to: datetime):
         out = []
         async def condition(dt, delta):
             return dt_intersect(dt_from, dt_to, dt, delta)