Fix sqs maps parsing

Signed-off-by: Valery Piashchynski <[email protected]>

1 files changed, 6 insertions, 20 deletions

diff --git a/plugins/jobs/drivers/sqs/consumer.go b/plugins/jobs/drivers/sqs/consumer.go
index 5d419b51..17af1caa 100644
--- a/plugins/jobs/drivers/sqs/consumer.go
+++ b/plugins/jobs/drivers/sqs/consumer.go
@@ -160,30 +160,16 @@ func FromPipeline(pipe *pipeline.Pipeline, log logger.Logger, cfg cfgPlugin.Conf
 
 	globalCfg.InitDefault()
 
-	res := make(map[string]interface{})
-	pipe.Map(attributes, res)
-
 	attr := make(map[string]string)
-	// accept only string values
-	for i := range res {
-		if v, ok := res[i].(string); ok {
-			attr[i] = v
-		}
-	}
-
-	// delete all values with map.clear to reuse for the tags
-	for k := range res {
-		delete(res, k)
+	err = pipe.Map(attributes, attr)
+	if err != nil {
+		return nil, errors.E(op, err)
 	}
 
-	pipe.Map(tags, res)
-
 	tg := make(map[string]string)
-	// accept only string values
-	for i := range res {
-		if v, ok := res[i].(string); ok {
-			attr[i] = v
-		}
+	err = pipe.Map(tags, tg)
+	if err != nil {
+		return nil, errors.E(op, err)
 	}
 
 	// initialize job consumer