File tree 1 file changed +3
-0
lines changed
1 file changed +3
-0
lines changed Original file line number Diff line number Diff line change @@ -87,6 +87,7 @@ func run(ctx context.Context, v Validator) {
87
87
select {
88
88
case <- ctx .Done ():
89
89
log .Info ("Context canceled, stopping validator" )
90
+ span .End ()
90
91
return // Exit if context is canceled.
91
92
case slot := <- v .NextSlot ():
92
93
span .AddAttributes (trace .Int64Attribute ("slot" , int64 (slot )))
@@ -111,6 +112,7 @@ func run(ctx context.Context, v Validator) {
111
112
if featureconfig .Get ().LocalProtection {
112
113
if err := v .UpdateProtections (ctx , slot ); err != nil {
113
114
log .WithError (err ).Error ("Could not update validator protection" )
115
+ span .End ()
114
116
continue
115
117
}
116
118
}
@@ -125,6 +127,7 @@ func run(ctx context.Context, v Validator) {
125
127
allRoles , err := v .RolesAt (ctx , slot )
126
128
if err != nil {
127
129
log .WithError (err ).Error ("Could not get validator roles" )
130
+ span .End ()
128
131
continue
129
132
}
130
133
for pubKey , roles := range allRoles {
You can’t perform that action at this time.
0 commit comments