Skip to content
View gist:7c7d39cbec69cea1e56a
WARN jepsen.core - Process 251 indeterminate
java.lang.IllegalArgumentException: Key must be integer
at clojure.lang.APersistentVector.assoc(
at clojure.lang.APersistentVector.assoc(
at clojure.lang.RT.assoc(
at clojure.core$assoc.invoke(core.clj:187)
at jepsen.disque$dequeue_BANG_.invoke(disque.clj:200)
at jepsen.disque.Client.invoke_BANG_(disque.clj:225)
at jepsen.core$worker$fn__3132$fn__3133.invoke(core.clj:133)
at jepsen.core$worker$fn__3132.invoke(core.clj:131)
View gist:fc58370111490f8d168f
Trying ::1...
Connected to localhost.
Escape character is '^]'.
-ERR Protocol error: expected '$', got '3'
Connection closed by foreign host.
View gist:9bde5f5dcee13e95c3c7

Job IDs

Disque jobs are uniquely identified by an ID like the following:


Job IDs always start with "DI" and end with "SQ" and are always composed of exactly 48 characters.

View gist:af0bf0cc40d86b405b26
ddd874d serializeJob(), sds concat logic fixed.
8220a01 NEEDJOBS fixes.
0b05ae6 Put the clusterNode name as first field.
69922f2 Federation: WIP, a few fixes.
a096b52 Federation: clusterSendYourJobs() WIP.
b9ba68c Federation: some API changes needed for YOURJOBS + more.
256fee3 Initially set queue atime to current unix time.
f359e2f Debugging printf() removed from needJobsForQueue().
6b1a575 Federation: more fixes to NEEDJOBS. Still WIP.
58e130f Federation: a few fixes to NEEDJOBS related functions.
View gist:4ad573085c40f98bfcba
./disque> qlen myqueue
(integer) 0> getjobs from myqueue
1) 1) "myqueue"
2) "DIf6c5b55b33c9cc2220740102a1935080e4e6863905a0SQ"
3) "myjob"
View gist:759d189e80220742a4e3
set foo '{"some_field":"1"}'
eval "return cjson.decode('get','foo'))['some_field']" 0
View xmas.c
#include <stdio.h>
#include <stdlib.h>
{int h=9,
x<39;x++){int a=x
View gist:5bd49d78efffda05c3b2> show DI0f0c644f9970a46cd1b2ce2ead31a30d8ad981d005a0SQ
1) "id"
2) "DI0f0c644f9970a46cd1b2ce2ead31a30d8ad981d005a0SQ"
3) "queue"
4) "myqueue"
5) "state"
6) "queued"
7) "repl"
8) (integer) 3
9) "ttl"
View gist:883ac85fa9d9fa80f74a
printf("%s -> %s\n", dictGetKey(entry), dictGetVal(entry));
printf("* %s\n", dictGetKey(entry2));
View gist:d72d58fbcdb278dda0e2> config set latency-monitor-threshold 10
OK> debug sleep .1
OK> debug sleep .2
OK> debug sleep .3
OK> latency doctor
Dave, I have observed latency spikes in this Redis instance.
Something went wrong with that request. Please try again.