Vincent Driessen
e278bd2967
Exit gracefully when user hits Ctrl+C in a worker.
...
The currently running task will be waited for, so it can gracefully
be finished. Further execution will be stopped.
If, during this waiting phase, Ctrl+C is hit again, the worker and the
horse will be terminated forcefully (this means work could be lost or
partially finished).
13 years ago
Vincent Driessen
ba965a1dd9
Minor text change
13 years ago
Vincent Driessen
2d2b351f7c
Change logging format.
13 years ago
Vincent Driessen
8678f26df0
Factor out call string.
13 years ago
Vincent Driessen
2ec12f1775
Fix bugje.
13 years ago
Vincent Driessen
1358246238
Better logging output.
13 years ago
Vincent Driessen
1dd73cb28d
Fix comment.
13 years ago
Vincent Driessen
d291f1dc4a
Text fix.
13 years ago
Vincent Driessen
ec4da2b3ad
Add sort-by-queue flag.
13 years ago
Vincent Driessen
cc8f05b3c6
Add __str__ to Job.
13 years ago
Vincent Driessen
fd3831f8f2
Fix b0rken test case due to new naming conventions.
13 years ago
Vincent Driessen
55fd393626
Worker.find_by_key method now returns None for nonexisting workers.
13 years ago
Vincent Driessen
507558f6bc
Avoid forked work horse to register death of its parent worker.
13 years ago
Vincent Driessen
bd1778c610
Fix comment typo's.
13 years ago
Vincent Driessen
0f38cfdd84
Add rqinfo -w command, to monitor active workers.
13 years ago
Vincent Driessen
4ad6281641
Rewrite the ANSI color formatter a bit.
13 years ago
Vincent Driessen
edcc012b2d
Document the Queue class.
13 years ago
Vincent Driessen
45700fc788
Delete unused file.
13 years ago
Vincent Driessen
c9ba66bd59
Register workers in a central set ("rq:workers").
13 years ago
Vincent Driessen
1f12678468
Get Worker fetch methods.
13 years ago
Vincent Driessen
9e8a4d15be
Document methods.
13 years ago
Vincent Driessen
6013227f4c
Remove unused property.
13 years ago
Vincent Driessen
aebfe74630
Add polling/scaling graphs.
13 years ago
Vincent Driessen
15c4efd2e1
Generate less intensive work.
13 years ago
Vincent Driessen
a905961f94
Add some sample scripts.
13 years ago
Vincent Driessen
a029e5437b
Add beginnings of a rqworker script.
13 years ago
Vincent Driessen
d780c929c0
Change semantics of work(). Add work_burst().
...
work() will now start the worker run loop, and work_burst() now leads to
the burst-then-quit behaviour.
13 years ago
Vincent Driessen
d761dd0280
Add BSD license, copied from git-flow.
13 years ago
Vincent Driessen
a491ff248d
Add simple helper function, to avoid users to learn about the `conn`
...
stack.
This makes it easier to start using the product.
13 years ago
Vincent Driessen
0ff2984adf
Use __slots__, for minimal memory overhead.
13 years ago
Vincent Driessen
ced001cbb9
Update README with some project values.
13 years ago
Vincent Driessen
56c4445bb2
Shut up pyflakes.
13 years ago
Vincent Driessen
b5ea5f32fe
Variable renamed.
13 years ago
Vincent Driessen
8852859fc4
Improved the __repr__ and __str__ of Queues.
13 years ago
Vincent Driessen
b4c1c85276
Add equality and comparison methods.
13 years ago
Vincent Driessen
a5ea45af57
Make the dequeue methods return values consistent.
...
I merely refactored the internal calls. No external API changes have been made in this commit. In order to make the dequeueing methods consistent, each dequeue method now returns a Job instance, which is just a nice lightweight wrapper around the job tuple.
The Job class makes it easier to pass the method call info around, along with some possible meta information, like the queue the job originated from.
This fixes #7 .
13 years ago
Vincent Driessen
f492a5ae2b
Restructure some code.
...
No functional change, but leave the BLPOP'ing to the Queue, as the
queues know how to pop themselves.
13 years ago
Vincent Driessen
652ced2580
Add sources of inspiration.
13 years ago
Vincent Driessen
f15f6d7843
Fix terminology.
13 years ago
Vincent Driessen
83e29ca987
Document how to start a worker.
13 years ago
Vincent Driessen
22f3da1832
Update README (and example).
13 years ago
Vincent Driessen
1a893e60cf
Have work() return whether work has been done, or not.
...
And promote Worker to the rq namespace, so you can
from rq import Worker
13 years ago
Vincent Driessen
1c9fa66bc1
Greatly simplify the setup.
...
Jobs don't even need to be tagged. Any function can be put on queues.
13 years ago
Vincent Driessen
62b6b180f3
Also allow args and kwargs to enqueue() calls on Queue.
13 years ago
Vincent Driessen
159eba6df2
Add arg to test case.
13 years ago
Vincent Driessen
fc5097ce7a
Better test naming.
13 years ago
Vincent Driessen
196a9815d2
Add dequeue method to Queue.
13 years ago
Vincent Driessen
b5e0377eb0
Allow jobs to be declared without a default queue.
...
This makes it impossible to use delay() on them. Instead, you should
use enqueue().
13 years ago
Vincent Driessen
407f3e8b38
Add ability to put work on alternate queues.
13 years ago
Vincent Driessen
1b8da4a861
Add test for putting work on queues.
13 years ago