|
22 | 22 |
|
23 | 23 | @runtime_checkable |
24 | 24 | class AsyncReportCB(Protocol): |
25 | | - async def __call__(self, report: ProgressReport) -> None: |
26 | | - ... |
| 25 | + async def __call__(self, report: ProgressReport) -> None: ... |
27 | 26 |
|
28 | 27 |
|
29 | 28 | @runtime_checkable |
30 | 29 | class ReportCB(Protocol): |
31 | | - def __call__(self, report: ProgressReport) -> None: |
32 | | - ... |
| 30 | + def __call__(self, report: ProgressReport) -> None: ... |
33 | 31 |
|
34 | 32 |
|
35 | 33 | def _normalize_weights(steps: int, weights: list[float]) -> list[float]: |
@@ -88,7 +86,7 @@ async def main_fct(): |
88 | 86 | progress_unit: ProgressUnit | None = None |
89 | 87 | progress_report_cb: AsyncReportCB | ReportCB | None = None |
90 | 88 | _current_steps: float = _INITIAL_VALUE |
91 | | - _currnet_attempt: int = 0 |
| 89 | + _current_attempt: int = 0 |
92 | 90 | _children: list["ProgressBarData"] = field(default_factory=list) |
93 | 91 | _parent: Optional["ProgressBarData"] = None |
94 | 92 | _continuous_value_lock: asyncio.Lock = field(init=False) |
@@ -148,7 +146,7 @@ async def _report_external(self, value: float) -> None: |
148 | 146 | # NOTE: here we convert back to actual value since this is possibly weighted |
149 | 147 | actual_value=value * self.num_steps, |
150 | 148 | total=self.num_steps, |
151 | | - attempt=self._currnet_attempt, |
| 149 | + attempt=self._current_attempt, |
152 | 150 | unit=self.progress_unit, |
153 | 151 | message=self.compute_report_message_stuct(), |
154 | 152 | ), |
@@ -200,7 +198,7 @@ async def update(self, steps: float = 1) -> None: |
200 | 198 | await self._report_external(new_progress_value) |
201 | 199 |
|
202 | 200 | def reset(self) -> None: |
203 | | - self._currnet_attempt += 1 |
| 201 | + self._current_attempt += 1 |
204 | 202 | self._current_steps = _INITIAL_VALUE |
205 | 203 | self._last_report_value = _INITIAL_VALUE |
206 | 204 |
|
|
0 commit comments