Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

delete incomplete files on assembler stop

Browse source
This commit is contained in:
Victor Shyba 2019-02-13 21:30:32 -03:00 committed by Lex Berezhny
parent d91e8f5996
commit dbc8cfe5ae
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
lbrynet/stream/assembler.py
View file

@ -128,6 +128,9 @@ class StreamAssembler:
else: else:
log.debug("stream decryption and assembly did not finish (%i/%i blobs are done)", written_blobs or 0, log.debug("stream decryption and assembly did not finish (%i/%i blobs are done)", written_blobs or 0,
len(self.descriptor.blobs) - 2) len(self.descriptor.blobs) - 2)
if self.stream_handle is not None and self.output_path is not None:
log.debug("erasing incomplete file assembly: %s", self.output_path)
os.unlink(self.output_path)
async def get_blob(self, blob_hash: str, length: typing.Optional[int] = None) -> 'BlobFile': async def get_blob(self, blob_hash: str, length: typing.Optional[int] = None) -> 'BlobFile':
return self.blob_manager.get_blob(blob_hash, length) return self.blob_manager.get_blob(blob_hash, length)