From db90a03c0119f7760fa8e5d86f8f78008090f03f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Toma=C5=BE=20Jerman?= Date: Mon, 23 Mar 2020 17:56:41 +0100 Subject: [PATCH] More descriptive stream splitting errors --- pkg/migrate/stream.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/migrate/stream.go b/pkg/migrate/stream.go index 26209dd8b..767276112 100644 --- a/pkg/migrate/stream.go +++ b/pkg/migrate/stream.go @@ -86,24 +86,24 @@ func splitStream(m types.Migrateable) ([]types.Migrateable, error) { if checkWhere(strmp["where"], record, hMap) { maps, ok := strmp["map"].([]interface{}) if !ok { - return nil, errors.New("streamMap.invalidMap") + return nil, errors.New("streamMap.invalidMap " + m.Name) } // populate splitted streams for _, mp := range maps { mm, ok := mp.(map[string]interface{}) if !ok { - return nil, errors.New("streamMap.map.invalidEntry") + return nil, errors.New("streamMap.map.invalidEntry " + m.Name) } from, ok := mm["from"].(string) if !ok { - return nil, errors.New("streamMap.map.entry.invalidFrom") + return nil, errors.New("streamMap.map.entry.invalidFrom " + m.Name) } to, ok := mm["to"].(string) if !ok { - return nil, errors.New("streamMap.map.invalidTo") + return nil, errors.New("streamMap.map.invalidTo " + m.Name) } vv := strings.Split(to, ".")