diff --git a/lbrynet/extras/daemon/Downloader.py b/lbrynet/extras/daemon/Downloader.py
index 9c7d4fc80..aaa843154 100644
--- a/lbrynet/extras/daemon/Downloader.py
+++ b/lbrynet/extras/daemon/Downloader.py
@@ -162,7 +162,7 @@ class GetStream:
     def _download(self, sd_blob, name, key_fee, txid, nout, file_name=None):
         self.downloader = yield self._create_downloader(sd_blob, file_name=file_name)
         yield self.pay_key_fee(key_fee, name)
-        yield self.storage.save_content_claim(self.downloader.stream_hash, "%s:%i" % (txid, nout))
+        yield f2d(self.storage.save_content_claim(self.downloader.stream_hash, "%s:%i" % (txid, nout)))
         self.finished_deferred = self.downloader.start()
         self.downloader.download_manager.progress_manager.wrote_first_data.addCallback(
             self.data_downloading_deferred.callback
diff --git a/lbrynet/extras/daemon/HashAnnouncer.py b/lbrynet/extras/daemon/HashAnnouncer.py
index 819f890fa..154038d3f 100644
--- a/lbrynet/extras/daemon/HashAnnouncer.py
+++ b/lbrynet/extras/daemon/HashAnnouncer.py
@@ -2,6 +2,7 @@ import binascii
 import logging
 
 from twisted.internet import defer, task
+from lbrynet.extras.compat import f2d
 from lbrynet import utils, conf
 
 log = logging.getLogger(__name__)
@@ -38,7 +39,7 @@ class DHTHashAnnouncer:
         now = self.clock.seconds()
         if storing_node_ids:
             result = (now, storing_node_ids)
-            yield self.storage.update_last_announced_blob(blob_hash, now)
+            yield f2d(self.storage.update_last_announced_blob(blob_hash, now))
             log.debug("Stored %s to %i peers", blob_hash[:16], len(storing_node_ids))
         else:
             result = (None, [])
@@ -82,7 +83,7 @@ class DHTHashAnnouncer:
         if not self.dht_node.contacts:
             log.info("Not ready to start announcing hashes")
             return
-        need_reannouncement = yield self.storage.get_blobs_to_announce()
+        need_reannouncement = yield f2d(self.storage.get_blobs_to_announce())
         if need_reannouncement:
             yield self.immediate_announce(need_reannouncement)
         else: