Skip to content

Commit 3026aa5

Browse files
Apply suggestions from code review
Co-authored-by: Marcos Nicolau <76252340+MarcosNicolau@users.noreply.github.com>
1 parent b0c2d14 commit 3026aa5

1 file changed

Lines changed: 1 addition & 2 deletions

File tree

core/chainio/avs_subscriber.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -127,7 +127,7 @@ func (s *AvsSubscriber) SubscribeToNewTasksV2(newTaskCreatedChan chan *servicema
127127
auxSub, errMain = SubscribeToNewTasksV2Retryable(&bind.WatchOpts{}, s.AvsContractBindings.ServiceManager, internalChannel, nil, retry.NetworkRetryParams())
128128
if errMain == nil {
129129
sub = auxSub // update the subscription only if it was successful
130-
s.logger.Info("Resubscribed to fallback new task subscription")
130+
s.logger.Info("Main connection resubscribed to new task subscription")
131131
}
132132
case err := <-subFallback.Err():
133133
s.logger.Warn("Error in new task subscription of fallback connection", "err", err)
@@ -154,7 +154,6 @@ func (s *AvsSubscriber) SubscribeToNewTasksV3(newTaskCreatedChan chan *servicema
154154
sub, errMain := SubscribeToNewTasksV3Retryable(&bind.WatchOpts{}, s.AvsContractBindings.ServiceManager, internalChannel, nil, retry.NetworkRetryParams())
155155
if errMain != nil {
156156
s.logger.Error(fmt.Sprintf("Fallback failed to subscribe to new AlignedLayer V3 tasks after %d retries", MaxRetries), "err", fmt.Sprintf("%v", errMain))
157-
//return err
158157
}
159158

160159
subFallback, errFallback := SubscribeToNewTasksV3Retryable(&bind.WatchOpts{}, s.AvsContractBindings.ServiceManagerFallback, internalChannel, nil, retry.NetworkRetryParams())

0 commit comments

Comments
 (0)