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 }