forked from LBRYCommunity/lbry-sdk
fix file_delete
This commit is contained in:
parent
64dffa306f
commit
cefe3eb520
1 changed files with 1 additions and 5 deletions
|
@ -141,11 +141,7 @@ class StreamManager:
|
||||||
blob_hashes = [stream.sd_hash]
|
blob_hashes = [stream.sd_hash]
|
||||||
for blob_info in stream.descriptor.blobs[:-1]:
|
for blob_info in stream.descriptor.blobs[:-1]:
|
||||||
blob_hashes.append(blob_info.blob_hash)
|
blob_hashes.append(blob_info.blob_hash)
|
||||||
for blob_hash in blob_hashes:
|
await self.blob_manager.delete_blobs(blob_hashes)
|
||||||
blob = self.blob_manager.get_blob(blob_hash)
|
|
||||||
if blob.get_is_verified():
|
|
||||||
await blob.delete()
|
|
||||||
|
|
||||||
if delete_file:
|
if delete_file:
|
||||||
path = os.path.join(stream.download_directory, stream.file_name)
|
path = os.path.join(stream.download_directory, stream.file_name)
|
||||||
if os.path.isfile(path):
|
if os.path.isfile(path):
|
||||||
|
|
Loading…
Reference in a new issue