diff --git a/radicle-node/src/service/gossip/store.rs b/radicle-node/src/service/gossip/store.rs
index 507e8341..9ae6dad8 100644
--- a/radicle-node/src/service/gossip/store.rs
+++ b/radicle-node/src/service/gossip/store.rs
@@ -363,15 +363,15 @@ mod parse {
         let gt = row.read::<GossipType, _>("type");
         let message = match gt {
             GossipType::Refs => {
-                let ann = row.read::<RefsAnnouncement, _>("message");
+                let ann = row.try_read::<RefsAnnouncement, _>("message")?;
                 AnnouncementMessage::Refs(ann)
             }
             GossipType::Inventory => {
-                let ann = row.read::<InventoryAnnouncement, _>("message");
+                let ann = row.try_read::<InventoryAnnouncement, _>("message")?;
                 AnnouncementMessage::Inventory(ann)
             }
             GossipType::Node => {
-                let ann = row.read::<NodeAnnouncement, _>("message");
+                let ann = row.try_read::<NodeAnnouncement, _>("message")?;
                 AnnouncementMessage::Node(ann)
             }
         };
diff --git a/radicle/src/node/db/migrations/6.sql b/radicle/src/node/db/migrations/6.sql
index 36aee208..86df381b 100644
--- a/radicle/src/node/db/migrations/6.sql
+++ b/radicle/src/node/db/migrations/6.sql
@@ -1,3 +1,5 @@
 -- Add the version and user-agent columns.
 alter table "nodes" add column "version" integer not null default 1;
 alter table "nodes" add column "agent" text not null default "/radicle/";
+-- Delete all cached announcements, since they no longer match our format.
+delete from "announcements";