Return if err in getting client

practo · Sep 22, 2020 · e20ba0a · e20ba0a
1 parent d345b7d
commit e20ba0a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/queue/beanstalk.go b/pkg/queue/beanstalk.go
@@ -325,7 +325,8 @@ func (b *Beanstalk) waitForShortPollInterval() {
 func (b *Beanstalk) reestablishConn(queueURI string) {
 	client, err := b.getClient(queueURI)
 	if err != nil {
-		klog.Error(err)
+		klog.Errorf("Could not reestablish conn, err:%v\n", err)
+		return
 	}
 
 	err = client.reestablishConn()