From 588d7e629ac68350ed6a2d0ed76e7f41d9463185 Mon Sep 17 00:00:00 2001 From: Josh Siegel Date: Thu, 12 Jan 2023 22:09:50 +0000 Subject: [PATCH] node: ether block pollers need to wrap their supervisor runs --- node/pkg/watchers/evm/connectors/logpoller.go | 2 +- node/pkg/watchers/evm/connectors/poller.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/node/pkg/watchers/evm/connectors/logpoller.go b/node/pkg/watchers/evm/connectors/logpoller.go index e3cbf0464..2b6563318 100644 --- a/node/pkg/watchers/evm/connectors/logpoller.go +++ b/node/pkg/watchers/evm/connectors/logpoller.go @@ -33,7 +33,7 @@ type LogPollConnector struct { func NewLogPollConnector(ctx context.Context, baseConnector Connector, client *ethClient.Client) (*LogPollConnector, error) { connector := &LogPollConnector{Connector: baseConnector, client: client} // The supervisor will keep the poller running - err := supervisor.Run(ctx, "logPoller", connector.run) + err := supervisor.Run(ctx, "logPoller", common.WrapWithScissors(connector.run, "logPoller")) if err != nil { return nil, err } diff --git a/node/pkg/watchers/evm/connectors/poller.go b/node/pkg/watchers/evm/connectors/poller.go index e71323433..2d5b9dc9a 100644 --- a/node/pkg/watchers/evm/connectors/poller.go +++ b/node/pkg/watchers/evm/connectors/poller.go @@ -44,7 +44,7 @@ func NewBlockPollConnector(ctx context.Context, baseConnector Connector, finaliz publishSafeBlocks: publishSafeBlocks, finalizer: finalizer, } - err := supervisor.Run(ctx, "blockPoller", connector.runFromSupervisor) + err := supervisor.Run(ctx, "blockPoller", common.WrapWithScissors(connector.runFromSupervisor, "blockPoller")) if err != nil { return nil, err }