From 742a92504091073ee7467af4685493bb8470ffa1 Mon Sep 17 00:00:00 2001 From: Tulir Asokan Date: Mon, 2 Aug 2021 12:52:05 +0300 Subject: [PATCH] Change some things --- mautrix_telegram/portal/telegram.py | 2 +- mautrix_telegram/util/parallel_file_transfer.py | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/mautrix_telegram/portal/telegram.py b/mautrix_telegram/portal/telegram.py index 4bab878c..626bfa85 100644 --- a/mautrix_telegram/portal/telegram.py +++ b/mautrix_telegram/portal/telegram.py @@ -410,7 +410,7 @@ class PortalTelegram(BasePortal, ABC): @staticmethod def _int_to_bytes(i: int) -> bytes: - hex_value = "{0:010x}".format(i).encode("utf-8") + hex_value = f"{i:010x}".encode("utf-8") return codecs.decode(hex_value, "hex_codec") def _encode_msgid(self, source: 'AbstractUser', evt: Message) -> str: diff --git a/mautrix_telegram/util/parallel_file_transfer.py b/mautrix_telegram/util/parallel_file_transfer.py index f8444083..9efcc02e 100644 --- a/mautrix_telegram/util/parallel_file_transfer.py +++ b/mautrix_telegram/util/parallel_file_transfer.py @@ -134,7 +134,7 @@ class ParallelTransferrer: self.upload_ticker = 0 async def _cleanup(self) -> None: - await asyncio.gather(*[sender.disconnect() for sender in self.senders]) + await asyncio.gather(*(sender.disconnect() for sender in self.senders)) self.senders = None @staticmethod @@ -161,9 +161,9 @@ class ParallelTransferrer: await self._create_download_sender(file, 0, part_size, connections * part_size, get_part_count()), *await asyncio.gather( - *[self._create_download_sender(file, i, part_size, connections * part_size, + *(self._create_download_sender(file, i, part_size, connections * part_size, get_part_count()) - for i in range(1, connections)]) + for i in range(1, connections))) ] async def _create_download_sender(self, file: TypeLocation, index: int, part_size: int, @@ -177,8 +177,8 @@ class ParallelTransferrer: self.senders = [ await self._create_upload_sender(file_id, part_count, big, 0, connections), *await asyncio.gather( - *[self._create_upload_sender(file_id, part_count, big, i, connections) - for i in range(1, connections)]) + *(self._create_upload_sender(file_id, part_count, big, i, connections) + for i in range(1, connections))) ] async def _create_upload_sender(self, file_id: int, part_count: int, big: bool, index: int,