@@ -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
@@ -134,7 +141,11 @@ def __init__(
134
141
135
142
self .loop : asyncio .AbstractEventLoop | None = loop
136
143
137
- self .name : str = f'pycord-ext-task ({ id (self ):#x} ): { coro .__qualname__ } ' if name in (None , MISSING ) else name
144
+ self .name : str = (
145
+ f"pycord-ext-task ({ id (self ):#x} ): { coro .__qualname__ } "
146
+ if name in (None , MISSING )
147
+ else name
148
+ )
138
149
self .count : int | None = count
139
150
self ._current_loop = 0
140
151
self ._handle : SleepHandle = MISSING
@@ -219,9 +230,12 @@ async def _loop(self, *args: Any, **kwargs: Any) -> None:
219
230
self ._last_iteration = self ._next_iteration
220
231
self ._next_iteration = self ._get_next_sleep_time ()
221
232
222
- while self ._expl_time () and self ._next_iteration <= self ._last_iteration :
233
+ while (
234
+ self ._expl_time ()
235
+ and self ._next_iteration <= self ._last_iteration
236
+ ):
223
237
_log .warning (
224
- ' Task %s woke up at %s, which was before expected (%s). Sleeping again to fix it...' ,
238
+ " Task %s woke up at %s, which was before expected (%s). Sleeping again to fix it..." ,
225
239
self .coro .__name__ ,
226
240
discord .utils .utcnow (),
227
241
self ._next_iteration ,
@@ -238,7 +252,7 @@ async def _loop(self, *args: Any, **kwargs: Any) -> None:
238
252
239
253
delay = backoff .delay ()
240
254
_log .warning (
241
- ' Received an exception which was in the valid exception set. Task will run again in %s.2f seconds' ,
255
+ " Received an exception which was in the valid exception set. Task will run again in %s.2f seconds" ,
242
256
self .coro .__name__ ,
243
257
delay ,
244
258
exc_info = exc ,
@@ -640,7 +654,9 @@ def error(self, coro: ET) -> ET:
640
654
self ._error = coro # type: ignore
641
655
return coro
642
656
643
- def _get_next_sleep_time (self , now : datetime .datetime = MISSING ) -> datetime .datetime :
657
+ def _get_next_sleep_time (
658
+ self , now : datetime .datetime = MISSING
659
+ ) -> datetime .datetime :
644
660
if self ._sleep is not MISSING :
645
661
return self ._last_iteration + datetime .timedelta (seconds = self ._sleep )
646
662
0 commit comments