Skip to content

Commit 44dea57

Browse files
authored
Fix cannot peak job from the v2 engine if it's sinked into the secondary storage (#215)
1 parent 1db0b63 commit 44dea57

File tree

2 files changed

+1
-4
lines changed

2 files changed

+1
-4
lines changed

engine/redis_v2/engine.go

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -218,9 +218,6 @@ func (e *Engine) Peek(namespace, queue, optionalJobID string) (job engine.Job, e
218218
}
219219
body = res[0].Body()
220220
}
221-
if err != nil {
222-
return nil, err
223-
}
224221
data := &model.JobData{}
225222
if err = proto.Unmarshal(body, data); err != nil {
226223
return nil, err

engine/redis_v2/engine_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -394,7 +394,7 @@ func TestEngine_Peek_SecondaryStorage(t *testing.T) {
394394
ID: "",
395395
Body: body,
396396
TTL: 120,
397-
Delay: 15,
397+
Delay: 45,
398398
Tries: 1,
399399
Attributes: attributes,
400400
})

0 commit comments

Comments
 (0)