diff --git a/lbrynet/core/server/BlobAvailabilityHandler.py b/lbrynet/core/server/BlobAvailabilityHandler.py
index 5203f72d2..a5d550bdf 100644
--- a/lbrynet/core/server/BlobAvailabilityHandler.py
+++ b/lbrynet/core/server/BlobAvailabilityHandler.py
@@ -44,6 +44,7 @@ class BlobAvailabilityHandler(object):
             d = self._get_available_blobs(queries[self.query_identifiers[0]])
 
             def set_field(available_blobs):
+                log.debug("available blobs: %s", str(available_blobs))
                 return {'available_blobs': available_blobs}
 
             d.addCallback(set_field)
diff --git a/lbrynet/reflector/server/server.py b/lbrynet/reflector/server/server.py
index 6d309cafa..7ea759f97 100644
--- a/lbrynet/reflector/server/server.py
+++ b/lbrynet/reflector/server/server.py
@@ -89,6 +89,7 @@ class ReflectorServer(Protocol):
         else:
             self.incoming_blob = blob
             self.blob_finished_d, self.blob_write, self.cancel_write = blob.open_for_writing(self.peer)
+            self.blob_finished_d.addCallback(lambda _: self.blob_manager.blob_completed(blob))
             return {'send_blob': True}
 
     def close_blob(self):