Don't include the original migration node for strem splitting

2020-03-22 12:08:20 +01:00
parent 4b995099d2
commit d4fdc7f63b
1 changed files with 1 additions and 1 deletions
@@ -29,8 +29,8 @@ type (
 // See readme for more info
 func splitStream(m types.Migrateable) ([]types.Migrateable, error) {
 	var rr []types.Migrateable
-	rr = append(rr, m)
 	if m.Map == nil {
+		rr = append(rr, m)
 		return rr, nil
 	}