Skip to content

Instantly share code, notes, and snippets.

@aenario
Last active May 17, 2017 15:46
Show Gist options
  • Save aenario/8c9f3eae50475041163eca9961c0965b to your computer and use it in GitHub Desktop.
Save aenario/8c9f3eae50475041163eca9961c0965b to your computer and use it in GitHub Desktop.
=== RUN TestInMemoryJobs
setNbSlots 4
setNbSlots 4
broker2 push &jobs.Message{Data:[]uint8{0x22, 0x62, 0x2d, 0x31, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc4201a42a0), Options:(*jobs.JobOptions)(nil)}
broker1 push &jobs.Message{Data:[]uint8{0x22, 0x61, 0x2d, 0x31, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc4201cc000), Options:(*jobs.JobOptions)(nil)}
Cannot save &jobs.JobInfos{JobID:"", JobRev:"", Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc4201a42a0), Options:(*jobs.JobOptions)(nil), State:"queued", QueuedAt:time.Time{sec:63630632713, nsec:590425291, loc:(*time.Location)(0xb06cc0)}, StartedAt:time.Time{sec:0, nsec:0, loc:(*time.Location)(nil)}, Error:""}: CouchDB(file_exists): The database could not be created, the file already exists.
broker2 push &jobs.Message{Data:[]uint8{0x22, 0x62, 0x2d, 0x32, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc4201cc570), Options:(*jobs.JobOptions)(nil)}
broker1 push &jobs.Message{Data:[]uint8{0x22, 0x61, 0x2d, 0x32, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc4201cca20), Options:(*jobs.JobOptions)(nil)}
broker2 push &jobs.Message{Data:[]uint8{0x22, 0x62, 0x2d, 0x33, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc42020a8a0), Options:(*jobs.JobOptions)(nil)}
broker1 push &jobs.Message{Data:[]uint8{0x22, 0x61, 0x2d, 0x33, 0x22}, Type:"json"}
broker2 push &jobs.Message{Data:[]uint8{0x22, 0x62, 0x2d, 0x34, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc42020af90), Options:(*jobs.JobOptions)(nil)}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc42017ea20), Options:(*jobs.JobOptions)(nil)}
Worker test b-2 %!s(<nil>)
Worker test a-1 %!s(<nil>)
Worker test a-2 %!s(<nil>)
Worker test b-3 %!s(<nil>)
broker2 push &jobs.Message{Data:[]uint8{0x22, 0x62, 0x2d, 0x35, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc4202a2000), Options:(*jobs.JobOptions)(nil)}
broker1 push &jobs.Message{Data:[]uint8{0x22, 0x61, 0x2d, 0x34, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc42028c000), Options:(*jobs.JobOptions)(nil)}
broker2 push &jobs.Message{Data:[]uint8{0x22, 0x62, 0x2d, 0x36, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc4201cd7a0), Options:(*jobs.JobOptions)(nil)}
Worker test b-4 %!s(<nil>)
Worker test a-3 %!s(<nil>)
broker2 push &jobs.Message{Data:[]uint8{0x22, 0x62, 0x2d, 0x37, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc42020bf50), Options:(*jobs.JobOptions)(nil)}
broker1 push &jobs.Message{Data:[]uint8{0x22, 0x61, 0x2d, 0x35, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc4202fa7b0), Options:(*jobs.JobOptions)(nil)}
broker2 push &jobs.Message{Data:[]uint8{0x22, 0x62, 0x2d, 0x38, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc420308660), Options:(*jobs.JobOptions)(nil)}
Worker test b-5 %!s(<nil>)
broker1 push &jobs.Message{Data:[]uint8{0x22, 0x61, 0x2d, 0x36, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc4202a2930), Options:(*jobs.JobOptions)(nil)}
Worker test b-6 %!s(<nil>)
Worker test a-5 %!s(<nil>)
broker1 push &jobs.Message{Data:[]uint8{0x22, 0x61, 0x2d, 0x37, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc42017f1a0), Options:(*jobs.JobOptions)(nil)}
Worker test a-4 %!s(<nil>)
broker2 push &jobs.Message{Data:[]uint8{0x22, 0x62, 0x2d, 0x39, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc4202fb530), Options:(*jobs.JobOptions)(nil)}
Worker test b-8 %!s(<nil>)
Worker test b-7 %!s(<nil>)
broker1 push &jobs.Message{Data:[]uint8{0x22, 0x61, 0x2d, 0x38, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc4202a3590), Options:(*jobs.JobOptions)(nil)}
broker2 push &jobs.Message{Data:[]uint8{0x22, 0x62, 0x2d, 0x31, 0x30, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc4202a39e0), Options:(*jobs.JobOptions)(nil)}
Worker test a-6 %!s(<nil>)
broker1 push &jobs.Message{Data:[]uint8{0x22, 0x61, 0x2d, 0x39, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc420368090), Options:(*jobs.JobOptions)(nil)}
Worker test a-8 %!s(<nil>)
Worker test a-7 %!s(<nil>)
Worker test b-9 %!s(<nil>)
broker1 push &jobs.Message{Data:[]uint8{0x22, 0x61, 0x2d, 0x31, 0x30, 0x22}, Type:"json"}
PushJob &jobs.JobRequest{Domain:"cozy.local", WorkerType:"test", Message:(*jobs.Message)(0xc42037a600), Options:(*jobs.JobOptions)(nil)}
Worker test b-10 %!s(<nil>)
Worker test a-10 %!s(<nil>)
Worker test a-9 %!s(<nil>)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment