Skip to content

Commit

Permalink
format & lint
Browse files Browse the repository at this point in the history
  • Loading branch information
calbera committed Jan 8, 2024
1 parent 59a631f commit 562babd
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion baseapp/job_manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -167,7 +167,7 @@ func (jm *JobManager) RunProducers(gctx context.Context) { //nolint:gocognit //
j := jm.jobRegistry.Get(jobID)
ctx := jm.ctxFactory.NewSDKContext(gctx)
if sj, ok := j.(job.HasSetup); ok {
if err := sj.Setup(ctx); err != nil {
if err = sj.Setup(ctx); err != nil {
panic(err)
}
}
Expand All @@ -190,6 +190,7 @@ func (jm *JobManager) RunProducers(gctx context.Context) { //nolint:gocognit //
})
} else if ethSubJob, ok := j.(job.EthSubscribable); ok { //nolint:govet // todo fix.
jm.jobProducers.Submit(withRetry(func() bool {
//nolint:govet // todo fix.
sub, ch, err := ethSubJob.Subscribe(ctx)
if err != nil {
jm.Logger(ctx).Error("error subscribing block header", "err", err)
Expand All @@ -214,6 +215,7 @@ func (jm *JobManager) RunProducers(gctx context.Context) { //nolint:gocognit //
}
}, jm.Logger(ctx)))
} else if blockHeaderJob, ok := j.(job.BlockHeaderSub); ok { //nolint:govet // todo fix.
//nolint:govet // todo fix.
jm.jobProducers.Submit(withRetry(func() bool {
sub, ch, err := blockHeaderJob.Subscribe(ctx)
if err != nil {
Expand Down

0 comments on commit 562babd

Please sign in to comment.