From 8fa759bd744bee45b1b7390662aa0f29a3a35c3a Mon Sep 17 00:00:00 2001 From: Bulat Kurbanov Date: Mon, 27 Jun 2022 19:02:12 +0300 Subject: [PATCH] Fix task cancelation --- src/app/services/fl_downloader.py | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/src/app/services/fl_downloader.py b/src/app/services/fl_downloader.py index 083156d..6d04afb 100644 --- a/src/app/services/fl_downloader.py +++ b/src/app/services/fl_downloader.py @@ -101,7 +101,7 @@ class FLDownloader(BaseDownloader): ): for task in done_tasks: try: - data = task.result() + data = await task await data[0].aclose() await data[1].aclose() @@ -129,9 +129,6 @@ class FLDownloader(BaseDownloader): data = task.result() for t_task in pending: - if not t_task.done() or t_task.cancelled(): - continue - t_task.cancel() await self._close_other_done(pending)