We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1611135 commit 6b732baCopy full SHA for 6b732ba
executor.go
@@ -140,14 +140,17 @@ func (s *executor) run(mainCtx context.Context,
140
go func() {
141
defer s.wg.Done()
142
143
- newSwap.execute(mainCtx, &executeConfig{
+ err := newSwap.execute(mainCtx, &executeConfig{
144
statusChan: statusChan,
145
sweeper: s.sweeper,
146
blockEpochChan: queue.ChanOut(),
147
timerFactory: s.executorConfig.createExpiryTimer,
148
loopOutMaxParts: s.executorConfig.loopOutMaxParts,
149
cancelSwap: s.executorConfig.cancelSwap,
150
}, height)
151
+ if err != nil && err != context.Canceled {
152
+ log.Errorf("Execute error: %v", err)
153
+ }
154
155
select {
156
case swapDoneChan <- swapID:
0 commit comments