Adding TODO.

artie-labs · Dec 4, 2024 · d560de7 · d560de7
1 parent 264ec76
commit d560de7
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/sources/mysql/streaming/dml.go b/sources/mysql/streaming/dml.go
@@ -23,6 +23,8 @@ func (i *Iterator) processDML(ts time.Time, event *replication.BinlogEvent) ([]l
 		return nil, nil
 	}
 
+	// TODO: We should check that tableAdapter's timestamp is not greater than the event's timestamp.
+
 	operation, err := convertHeaderToOperation(event.Header.EventType)
 	if err != nil {
 		return nil, fmt.Errorf("failed to convert header to operation: %w", err)