fix(SQS): Log errors with SQS connections. Fixes argoproj#1114 (argop…

…roj#1115) * Add additional logging to expose errors when connecting to AWS SQS Signed-off-by: Orion Delwaterman <delwaterman@gmail.com> * Add Greenhouse as users Signed-off-by: Orion Delwaterman <delwaterman@gmail.com>
icecoffee531 · Mar 15, 2021 · 1cc31c1 · 1cc31c1
1 parent ad2fb83
commit 1cc31c1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git a/USERS.md b/USERS.md
@@ -8,6 +8,7 @@ Organizations below are **officially** using Argo Events. Please send a PR with
 1. [Canva](https://www.canva.com/)
 1. [DevSamurai](https://www.devsamurai.com/)
 1. [Fairwinds](https://fairwinds.com/)
+1. [Greenhouse Software](https://www.greenhouse.io/)
 1. [InsideBoard](https://www.insideboard.com)
 1. [Intuit](https://www.intuit.com/)
 1. [OneCause](https://www.onecause.com/)

diff --git a/eventsources/sources/awssqs/start.go b/eventsources/sources/awssqs/start.go
@@ -70,6 +70,7 @@ func (el *EventListener) StartListening(ctx context.Context, dispatch func([]byt
 	var awsSession *session.Session
 	awsSession, err := awscommon.CreateAWSSessionWithCredsInVolume(sqsEventSource.Region, sqsEventSource.RoleARN, sqsEventSource.AccessKey, sqsEventSource.SecretKey)
 	if err != nil {
+		log.Errorw("Error creating AWS credentials", zap.Error(err))
 		return errors.Wrapf(err, "failed to create aws session for %s", el.GetEventName())
 	}
 
@@ -85,6 +86,7 @@ func (el *EventListener) StartListening(ctx context.Context, dispatch func([]byt
 
 	queueURL, err := sqsClient.GetQueueUrl(getQueueURLInput)
 	if err != nil {
+		log.Errorw("Error getting SQS Queue URL", zap.Error(err))
 		return errors.Wrapf(err, "failed to get the queue url for %s", el.GetEventName())
 	}