diff --git a/aggregator/db/migrations/003.sql b/aggregator/db/migrations/0003.sql
similarity index 100%
rename from aggregator/db/migrations/003.sql
rename to aggregator/db/migrations/0003.sql
diff --git a/sequencesender/sequencesender.go b/sequencesender/sequencesender.go
index 70f6e90e..a2572d6e 100644
--- a/sequencesender/sequencesender.go
+++ b/sequencesender/sequencesender.go
@@ -874,6 +874,12 @@ func (s *SequenceSender) handleReceivedDataStream(entry *datastreamer.FileEntry,
 				entry.Number, l2Tx.L2BlockNumber, l2Tx.Index, s.entryTypeToString(prevEntryType), s.prevStreamEntry.Number)
 		}
 
+		// Sanity check: tx should be decodable
+		_, err = state.DecodeTx(common.Bytes2Hex(l2Tx.Encoded))
+		if err != nil {
+			log.Fatalf("error decoding tx during sanity check: %v", err)
+		}
+
 		// Add tx data
 		s.addNewBlockTx(l2Tx)