let cancel propagate

This commit is contained in:
Victor Shyba 2019-02-01 16:02:46 -03:00
parent 25050fdeeb
commit 832be0758b

View file

@ -57,6 +57,7 @@ class BlobDownloader:
await asyncio.wait(tasks, loop=self.loop, return_when='FIRST_COMPLETED')
except asyncio.CancelledError:
drain_tasks(tasks)
raise
async def download_blob(self, blob_hash: str, length: typing.Optional[int] = None) -> 'BlobFile':
blob = self.blob_manager.get_blob(blob_hash, length)