Skip to content

Commit

Permalink
Merge pull request #2 from tokopedia/b_john_enq_uniq_bugs
Browse files Browse the repository at this point in the history
fixed bugs on EnqueueUniqueInByKey (uniqueJobHelper)
  • Loading branch information
adzimzf authored Sep 26, 2019
2 parents c6205a5 + c4979a2 commit 4c7b141
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions worker.go
Original file line number Diff line number Diff line change
Expand Up @@ -254,6 +254,10 @@ func (w *worker) getAndDeleteUniqueJob(job *Job) *Job {
return nil
}

// JSON processing in Go differs from what Redis does (the order of values will be altered)
// we will use old JSON (not changing it), because the new JSON will have its data order altered
// for now we will stay using the old JSON, as we yet to have the solution to uniform the JSON
rawJSON = job.rawJSON
// The job pulled off the queue was just a placeholder with no args, so replace it
jobWithArgs, err := newJob(rawJSON, job.dequeuedFrom, job.inProgQueue)
if err != nil {
Expand Down

0 comments on commit 4c7b141

Please sign in to comment.