[ingest][verify] fix typo in error message

neicnordic · Oct 3, 2023 · 8c0f632 · 8c0f632
1 parent e91a14a
commit 8c0f632
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/sda/cmd/ingest/ingest.go b/sda/cmd/ingest/ingest.go
@@ -116,7 +116,7 @@ func main() {
 
 				body, _ := json.Marshal(infoErrorMessage)
 				if err := mq.SendMessage(delivered.CorrelationId, conf.Broker.Exchange, "error", body); err != nil {
-					log.Errorf("failed so publish message, reason: (%v)", err.Error())
+					log.Errorf("failed to publish message, reason: (%v)", err.Error())
 				}
 				if err := delivered.Ack(false); err != nil {
 					log.Errorf("Failed acking canceled work, reason: (%v)", err.Error())
@@ -173,7 +173,7 @@ func main() {
 					}
 					body, _ := json.Marshal(fileError)
 					if err := mq.SendMessage(delivered.CorrelationId, conf.Broker.Exchange, "error", body); err != nil {
-						log.Errorf("failed so publish message, reason: (%v)", err.Error())
+						log.Errorf("failed to publish message, reason: (%v)", err.Error())
 					}
 					if err = delivered.Ack(false); err != nil {
 						log.Errorf("Failed to Ack message, reason: (%v)", err.Error())
@@ -199,7 +199,7 @@ func main() {
 					}
 					body, _ := json.Marshal(fileError)
 					if err = mq.SendMessage(delivered.CorrelationId, conf.Broker.Exchange, "error", body); err != nil {
-						log.Errorf("failed so publish message, reason: (%v)", err.Error())
+						log.Errorf("failed to publish message, reason: (%v)", err.Error())
 					}
 
 					// Restart on new message
@@ -278,7 +278,7 @@ func main() {
 							}
 							body, _ := json.Marshal(fileError)
 							if err := mq.SendMessage(delivered.CorrelationId, conf.Broker.Exchange, "error", body); err != nil {
-								log.Errorf("failed so publish message, reason: (%v)", err.Error())
+								log.Errorf("failed to publish message, reason: (%v)", err.Error())
 							}
 
 							continue mainWorkLoop

diff --git a/sda/cmd/verify/verify.go b/sda/cmd/verify/verify.go
@@ -82,7 +82,7 @@ func main() {
 
 				body, _ := json.Marshal(infoErrorMessage)
 				if err := mq.SendMessage(delivered.CorrelationId, conf.Broker.Exchange, "error", body); err != nil {
-					log.Errorf("failed so publish message, reason: %v", err.Error())
+					log.Errorf("failed to publish message, reason: %v", err.Error())
 				}
 				if err := delivered.Ack(false); err != nil {
 					log.Errorf("Failed to Ack message, reason: %v", err.Error())
@@ -113,7 +113,7 @@ func main() {
 
 				body, _ := json.Marshal(infoErrorMessage)
 				if err := mq.SendMessage(delivered.CorrelationId, conf.Broker.Exchange, "error", body); err != nil {
-					log.Errorf("failed so publish message, reason: %v", err.Error())
+					log.Errorf("failed to publish message, reason: %v", err.Error())
 				}
 
 				if err := delivered.Ack(false); err != nil {
@@ -151,7 +151,7 @@ func main() {
 
 				// Send the message to an error queue so it can be analyzed.
 				if err := mq.SendMessage(delivered.CorrelationId, conf.Broker.Exchange, "error", body); err != nil {
-					log.Errorf("failed so publish message, reason: %v", err.Error())
+					log.Errorf("failed to publish message, reason: %v", err.Error())
 				}
 
 				continue
@@ -257,7 +257,7 @@ func main() {
 
 					body, _ := json.Marshal(infoErrorMessage)
 					if err := mq.SendMessage(delivered.CorrelationId, conf.Broker.Exchange, "error", body); err != nil {
-						log.Errorf("failed so publish message, reason: %v", err.Error())
+						log.Errorf("failed to publish message, reason: %v", err.Error())
 					}
 
 					if err := delivered.Ack(false); err != nil {