diff --git a/syncapi/streams/stream_pdu.go b/syncapi/streams/stream_pdu.go
index 8cee290f4..790f5bd1b 100644
--- a/syncapi/streams/stream_pdu.go
+++ b/syncapi/streams/stream_pdu.go
@@ -208,9 +208,6 @@ func (p *PDUStreamProvider) IncrementalSync(
 		req.Log.WithError(err).Error("unable to get recent events")
 		return r.From
 	}
-	if len(dbEvents) == 0 {
-		return r.To
-	}
 
 	newPos = from
 	for _, delta := range stateDeltas {