Skip to content

Commit f252dee

Browse files
committed
Check error when setting active execution
1 parent d35ab50 commit f252dee

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

backend/redis/instance.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,9 @@ func createInstanceP(ctx context.Context, p redis.Pipeliner, instance *core.Work
163163
p.SetNX(ctx, key, string(b), 0)
164164

165165
// The newly created instance is going to be the active execution
166-
setActiveInstanceExecutionP(ctx, p, instance)
166+
if err := setActiveInstanceExecutionP(ctx, p, instance); err != nil {
167+
return fmt.Errorf("setting active instance execution: %w", err)
168+
}
167169

168170
p.ZAdd(ctx, instancesByCreation(), redis.Z{
169171
Member: instanceSegment(instance),

0 commit comments

Comments
 (0)