Add more EventSource event logs for failed to publish events (#3147)

argoproj · May 29, 2024 · 70689c7 · 70689c7
1 parent 6d71abd
commit 70689c7
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/USERS.md b/USERS.md
@@ -52,3 +52,4 @@ Organizations below are **officially** using Argo Events. Please send a PR with
 1. [Yubo](https://www.yubo.live/)
 1. [WooliesX](https://wooliesx.com.au/)
 1. [Woolworths Group](https://www.woolworthsgroup.com.au/)
+1. [Zillow Group](https://www.zillow.com)
diff --git a/eventsources/eventing.go b/eventsources/eventing.go
@@ -579,12 +579,12 @@ func (e *EventSourceAdaptor) run(ctx context.Context, servers map[apicommon.Even
  },
  Body: eventBody,
  }
-
+ logger.Debugw(string(data), zap.String("eventID", event.ID()))
  if err = common.DoWithRetry(&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()))
+ s.GetEventName()), zap.Any(logging.LabelEventSourceType, s.GetEventSourceType()), zap.String("eventID", event.ID()))
  e.metrics.EventSentFailed(s.GetEventSourceName(), s.GetEventName())
  return eventbuscommon.NewEventBusError(err)
  }