feat: retry failed eventbus message publishing (#2162)

Signed-off-by: Derek Wang <[email protected]> Signed-off-by: Derek Wang <[email protected]>
argoproj · Sep 10, 2022 · e52ad74 · e52ad74
1 parent 7e424dc
commit e52ad74
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/eventsources/eventing.go b/eventsources/eventing.go
@@ -529,7 +529,9 @@ func (e *EventSourceAdaptor) run(ctx context.Context, servers map[apicommon.Even
 							Body: eventBody,
 						}
 
-						if err = e.eventBusConn.Publish(ctx, msg); err != nil {
+						if err = common.Connect(&common.DefaultBackoff, func() error {
+							return e.eventBusConn.Publish(ctx, msg)
+						}); err != nil {
 							logger.Errorw("failed to publish an event", zap.Error(err), zap.String(logging.LabelEventName,
 								s.GetEventName()), zap.Any(logging.LabelEventSourceType, s.GetEventSourceType()))
 							e.metrics.EventSentFailed(s.GetEventSourceName(), s.GetEventName())