diff --git a/pkg/coordinator/tasks/generate_bls_changes/task.go b/pkg/coordinator/tasks/generate_bls_changes/task.go index b4d1946..10eb1eb 100644 --- a/pkg/coordinator/tasks/generate_bls_changes/task.go +++ b/pkg/coordinator/tasks/generate_bls_changes/task.go @@ -142,6 +142,7 @@ func (t *Task) Execute(ctx context.Context) error { if err != nil { t.logger.Errorf("error generating bls change: %v", err.Error()) } else { + t.ctx.SetResult(types.TaskResultSuccess) perSlotCount++ totalCount++ } diff --git a/pkg/coordinator/tasks/generate_deposits/task.go b/pkg/coordinator/tasks/generate_deposits/task.go index fa1d714..1e3f798 100644 --- a/pkg/coordinator/tasks/generate_deposits/task.go +++ b/pkg/coordinator/tasks/generate_deposits/task.go @@ -153,6 +153,7 @@ func (t *Task) Execute(ctx context.Context) error { if err != nil { t.logger.Errorf("error generating deposit: %v", err.Error()) } else { + t.ctx.SetResult(types.TaskResultSuccess) perSlotCount++ totalCount++ } diff --git a/pkg/coordinator/tasks/generate_exits/task.go b/pkg/coordinator/tasks/generate_exits/task.go index b100fef..a50aec7 100644 --- a/pkg/coordinator/tasks/generate_exits/task.go +++ b/pkg/coordinator/tasks/generate_exits/task.go @@ -134,6 +134,7 @@ func (t *Task) Execute(ctx context.Context) error { if err != nil { t.logger.Errorf("error generating voluntary exit: %v", err.Error()) } else { + t.ctx.SetResult(types.TaskResultSuccess) perSlotCount++ totalCount++ } diff --git a/pkg/coordinator/tasks/generate_slashings/task.go b/pkg/coordinator/tasks/generate_slashings/task.go index 5bf001d..f9e79c3 100644 --- a/pkg/coordinator/tasks/generate_slashings/task.go +++ b/pkg/coordinator/tasks/generate_slashings/task.go @@ -136,6 +136,7 @@ func (t *Task) Execute(ctx context.Context) error { if err != nil { t.logger.Errorf("error generating slashing: %v", err.Error()) } else { + t.ctx.SetResult(types.TaskResultSuccess) perSlotCount++ totalCount++ }