diff --git a/lbrynet/extras/daemon/Daemon.py b/lbrynet/extras/daemon/Daemon.py
index d39c4b844..2348557bb 100644
--- a/lbrynet/extras/daemon/Daemon.py
+++ b/lbrynet/extras/daemon/Daemon.py
@@ -670,8 +670,8 @@ class Daemon(metaclass=JSONRPCServerType):
                     claim_dict, name, txid, nout, file_name
                 ))
                 finished_deferred.addCallbacks(
-                    lambda _: _download_finished(download_id, name, claim_dict),
-                    lambda e: _download_failed(e, download_id, name, claim_dict)
+                    lambda _: asyncio.create_task(_download_finished(download_id, name, claim_dict)),
+                    lambda e: asyncio.create_task(_download_failed(e, download_id, name, claim_dict))
                 )
                 result = await self._get_lbry_file_dict(lbry_file)
             except Exception as err:
diff --git a/lbrynet/extras/reflector/client/client.py b/lbrynet/extras/reflector/client/client.py
index 4fd76fb2c..6e00004b6 100644
--- a/lbrynet/extras/reflector/client/client.py
+++ b/lbrynet/extras/reflector/client/client.py
@@ -116,7 +116,7 @@ class EncryptedFileReflectorClient(Protocol):
             for crypt_blob in blobs:
                 if crypt_blob.blob_hash and crypt_blob.length:
                     yield self.blob_manager.get_blob(crypt_blob.blob_hash, crypt_blob.length)
-        return [blob for r, blob in get_blobs(blobs_in_stream) if r and blob.get_is_verified()]
+        return [blob for blob in get_blobs(blobs_in_stream) if blob.get_is_verified()]
 
     def set_blobs_to_send(self, blobs_to_send):
         for blob in blobs_to_send: