From 7fb3400d564d6bc87bb5176724679acd2da67e2f Mon Sep 17 00:00:00 2001 From: Justin Tieri <37750742+jtieri@users.noreply.github.com> Date: Thu, 14 Mar 2024 15:48:56 -0500 Subject: [PATCH] chore: add chain and client ids to incomplete flush log output --- relayer/processor/path_processor.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/relayer/processor/path_processor.go b/relayer/processor/path_processor.go index b8b9d4da2..a6e31bd60 100644 --- 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()