set success result for generate_* tasks once the first action has bee…

…n sent
ethpandaops · Feb 5, 2024 · 83b48f4 · 83b48f4
1 parent f7d640f
commit 83b48f4
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 0 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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++
 		}