diff --git a/CHANGELOG.md b/CHANGELOG.md index ce7b82270..a9e814d9f 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -13,7 +13,7 @@ at anytime. * ### Fixed - * Fixed non-blocking call in `BlobFile._close_writer` + * * ### Deprecated diff --git a/lbrynet/core/HashBlob.py b/lbrynet/core/HashBlob.py index 7494a606d..4d1521d0b 100644 --- a/lbrynet/core/HashBlob.py +++ b/lbrynet/core/HashBlob.py @@ -273,13 +273,12 @@ class BlobFile(HashBlob): file_handle.close() self.readers -= 1 - @defer.inlineCallbacks def _close_writer(self, writer): if writer.write_handle is not None: log.debug("Closing %s", str(self)) name = writer.write_handle.name writer.write_handle.close() - yield threads.deferToThread(os.remove, name) + threads.deferToThread(os.remove, name) writer.write_handle = None def _save_verified_blob(self, writer):