chore: add chain and client ids to incomplete flush log output

cosmos · Mar 14, 2024 · 7fb3400 · 7fb3400
1 parent c4eac28
commit 7fb3400
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/relayer/processor/path_processor.go b/relayer/processor/path_processor.go
@@ -296,7 +296,12 @@ func (pp *PathProcessor) HandleNewData(chainID string, cacheData ChainProcessorC
 func (pp *PathProcessor) handleFlush(ctx context.Context) {
 	flushTimer := pp.flushInterval
 	if err := pp.flush(ctx); err != nil {
-		pp.log.Warn("Flush not complete", zap.Error(err))
+		pp.log.Warn("Flush not complete",
+			zap.String("chain_id_1", pp.pathEnd1.chainProvider.ChainId()),
+			zap.String("client_id_1", pp.pathEnd1.info.ClientID),
+			zap.String("chain_id_2", pp.pathEnd2.chainProvider.ChainId()),
+			zap.String("client_id_2", pp.pathEnd2.info.ClientID),
+			zap.Error(err))
 		flushTimer = flushFailureRetry
 	}
 	pp.flushTimer.Stop()