diff --git a/pkg/migrate/stream.go b/pkg/migrate/stream.go index 446679ff8..3dee6082c 100644 --- a/pkg/migrate/stream.go +++ b/pkg/migrate/stream.go @@ -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 }