|
7 | 7 | from collections.abc import Generator, Iterable |
8 | 8 | from logging import Logger |
9 | 9 | from pathlib import Path |
10 | | -from typing import TYPE_CHECKING, Any, Dict, Type, Union |
| 10 | +from typing import TYPE_CHECKING, Any, Dict, Type |
11 | 11 |
|
12 | 12 | from . import utils |
13 | 13 | from .app_management import UpdateMode |
@@ -107,23 +107,6 @@ def is_ready(self) -> bool: |
107 | 107 | def set_log_level(self, level): |
108 | 108 | self.logger.setLevel(self.AD.logging.log_levels[level]) |
109 | 109 |
|
110 | | - async def perf_data(self) -> Dict[str, Union[int, float]]: |
111 | | - data = { |
112 | | - "bytes_sent": self.bytes_sent, |
113 | | - "bytes_recv": self.bytes_recv, |
114 | | - "requests_sent": self.requests_sent, |
115 | | - "updates_recv": self.updates_recv, |
116 | | - "duration": await self.AD.sched.get_now_ts() - self.last_check_ts, |
117 | | - } |
118 | | - |
119 | | - self.bytes_sent = 0 |
120 | | - self.bytes_recv = 0 |
121 | | - self.requests_sent = 0 |
122 | | - self.updates_recv = 0 |
123 | | - self.last_check_ts = await self.AD.sched.get_now_ts() |
124 | | - |
125 | | - return data |
126 | | - |
127 | 110 | def update_perf(self, **kwargs): |
128 | 111 | self.bytes_sent += kwargs.get("bytes_sent", 0) |
129 | 112 | self.bytes_recv += kwargs.get("bytes_recv", 0) |
|
0 commit comments