Log egressID in io client worker (#1054)

biglittlebigben · web-flow · commit 71444a1ea97c · 2025-11-06T19:32:49.000-08:00
diff --git a/pkg/info/io.go b/pkg/info/io.go
@@ -212,7 +212,7 @@ func (c *ioClient) handleUpdate(w *worker, egressID string) {
 		if _, err := c.IOInfoClient.UpdateEgress(u.ctx, u.info, psrpc.WithRequestTimeout(c.updateTimeout)); err != nil {
 			if isRetryableError(err) {
 				if c.healthy.Swap(false) {
-					logger.Warnw("io connection unhealthy", err)
+					logger.Warnw("io connection unhealthy", err, "egressID", u.info.EgressId)
 				}
 				d = min(d*2, maxBackoff)
 				time.Sleep(d)
@@ -224,7 +224,7 @@ func (c *ioClient) handleUpdate(w *worker, egressID string) {
 		}
 
 		if !c.healthy.Swap(true) {
-			logger.Infow("io connection restored")
+			logger.Infow("io connection restored", "egressID", u.info.EgressId)
 		}
 		requestType, outputType := egress.GetTypes(u.info.Request)
 		logger.Infow(strings.ToLower(u.info.Status.String()),

Original file line number	Diff line number	Diff line change
`@@ -212,7 +212,7 @@ func (c ioClient) handleUpdate(w worker, egressID string) {`
`212`	`212`	`if _, err := c.IOInfoClient.UpdateEgress(u.ctx, u.info, psrpc.WithRequestTimeout(c.updateTimeout)); err != nil {`
`213`	`213`	`if isRetryableError(err) {`
`214`	`214`	`if c.healthy.Swap(false) {`
`215`		`- logger.Warnw("io connection unhealthy", err)`
	`215`	`+ logger.Warnw("io connection unhealthy", err, "egressID", u.info.EgressId)`
`216`	`216`	`}`
`217`	`217`	`d = min(d*2, maxBackoff)`
`218`	`218`	`time.Sleep(d)`
`@@ -224,7 +224,7 @@ func (c ioClient) handleUpdate(w worker, egressID string) {`
`224`	`224`	`}`
`225`	`225`
`226`	`226`	`if !c.healthy.Swap(true) {`
`227`		`- logger.Infow("io connection restored")`
	`227`	`+ logger.Infow("io connection restored", "egressID", u.info.EgressId)`
`228`	`228`	`}`
`229`	`229`	`requestType, outputType := egress.GetTypes(u.info.Request)`
`230`	`230`	`logger.Infow(strings.ToLower(u.info.Status.String()),`