32
32
import sys
33
33
import traceback
34
34
from collections .abc import Sequence
35
- from typing import Any , Awaitable , Callable , Generic , TypeVar , cast
35
+ from typing import Any , Awaitable , Callable , Generic , TypeVar
36
36
37
37
import aiohttp
38
38
@@ -68,7 +68,12 @@ def is_imaginary(dt: datetime.datetime) -> bool:
68
68
69
69
tz = dt .tzinfo
70
70
dt = dt .replace (tzinfo = None )
71
- roundtrip = dt .replace (tzinfo = tz ).astimezone (datetime .timezone .utc ).astimezone (tz ).replace (tzinfo = None )
71
+ roundtrip = (
72
+ dt .replace (tzinfo = tz )
73
+ .astimezone (datetime .timezone .utc )
74
+ .astimezone (tz )
75
+ .replace (tzinfo = None )
76
+ )
72
77
return dt != roundtrip
73
78
74
79
@@ -91,7 +96,9 @@ def _safe_result(future: asyncio.Future) -> None:
91
96
def recalculate (self , dt : datetime .datetime ) -> None :
92
97
self .handle .cancel ()
93
98
relative_delta = discord .utils .compute_timedelta (dt )
94
- self .handle = self .loop .call_later (relative_delta , self ._safe_result , self .future )
99
+ self .handle = self .loop .call_later (
100
+ relative_delta , self ._safe_result , self .future
101
+ )
95
102
96
103
def wait (self ) -> asyncio .Future [Any ]:
97
104
return self .future
@@ -133,7 +140,11 @@ def __init__(
133
140
134
141
self .loop = loop
135
142
136
- self .name : str = f'pycord-ext-task ({ id (self ):#x} ): { coro .__qualname__ } ' if name in (None , MISSING ) else name
143
+ self .name : str = (
144
+ f"pycord-ext-task ({ id (self ):#x} ): { coro .__qualname__ } "
145
+ if name in (None , MISSING )
146
+ else name
147
+ )
137
148
self .count : int | None = count
138
149
self ._current_loop = 0
139
150
self ._handle : SleepHandle = MISSING
@@ -214,9 +225,12 @@ async def _loop(self, *args: Any, **kwargs: Any) -> None:
214
225
self ._last_iteration = self ._next_iteration
215
226
self ._next_iteration = self ._get_next_sleep_time ()
216
227
217
- while self ._expl_time () and self ._next_iteration <= self ._last_iteration :
228
+ while (
229
+ self ._expl_time ()
230
+ and self ._next_iteration <= self ._last_iteration
231
+ ):
218
232
_log .warning (
219
- ' Task %s woke up at %s, which was before expected (%s). Sleeping again to fix it...' ,
233
+ " Task %s woke up at %s, which was before expected (%s). Sleeping again to fix it..." ,
220
234
self .coro .__name__ ,
221
235
discord .utils .utcnow (),
222
236
self ._next_iteration ,
@@ -233,7 +247,7 @@ async def _loop(self, *args: Any, **kwargs: Any) -> None:
233
247
234
248
delay = backoff .delay ()
235
249
_log .warning (
236
- ' Received an exception which was in the valid exception set. Task will run again in %s.2f seconds' ,
250
+ " Received an exception which was in the valid exception set. Task will run again in %s.2f seconds" ,
237
251
self .coro .__name__ ,
238
252
delay ,
239
253
exc_info = exc ,
@@ -626,7 +640,9 @@ def error(self, coro: ET) -> ET:
626
640
self ._error = coro # type: ignore
627
641
return coro
628
642
629
- def _get_next_sleep_time (self , now : datetime .datetime = MISSING ) -> datetime .datetime :
643
+ def _get_next_sleep_time (
644
+ self , now : datetime .datetime = MISSING
645
+ ) -> datetime .datetime :
630
646
if self ._sleep is not MISSING :
631
647
return self ._last_iteration + datetime .timedelta (seconds = self ._sleep )
632
648
0 commit comments