From d4fdc7f63b49ad65cd9e066d07b66a39cde63a2e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Toma=C5=BE=20Jerman?= Date: Wed, 18 Mar 2020 18:21:45 +0100 Subject: [PATCH] Don't include the original migration node for strem splitting --- pkg/migrate/stream.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 }