util
/
rq
mirror of https://github.com/peter4431/rq.git
3
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity
1,287 Commits
2 Branches
0 Tags
3.3 MiB
Commit Graph

1287 Commits (92c88d3f4da0f17b5c2d927a18282819e74e0fa6)
 

Author SHA1 Message Date
Vincent Driessen 253f1752b8 Shorter logbook format on standard output, for readability. 
Still, the original output can be seen using the `--verbose` flag.
Vincent Driessen 62949c9adb Extra debug output.
Vincent Driessen dde3ea8ef7 Take down horse process when the worker is terminated.
Vincent Driessen 4ac243b3e8 Print what signal was received in a debug statement.
Vincent Driessen 7769d9875f Perform a warm shutdown on SIGTERM, too. 
Just like with Ctrl+C (SIGINT), shutdown warmly at first when kill'ed
(SIGTERM).
Vincent Driessen 3ecda16665 Fix output.
Vincent Driessen 7841e23cc4 Add procname dependency. 
Eventually, this will be optional, but for now, include it as there
actually *is* a dependency.
Vincent Driessen 213ac73e19 Remove blinker dependency.
Vincent Driessen 5dba007222 Add script to calculate project size. 
This will help keep the "lightweight" claim up.
Vincent Driessen 88cbaa1df9 Slight code reshuffle + added some comments on the construction.
Vincent Driessen 7cba8449d9 Add comments.
Vincent Driessen 1cbf92c166 Workaround for os.waitpid() throwing an OSError on SIGINT. 
When SIGINT (``Ctrl+C``) is received when inside a blocking
os.waitpid(), OSError is thrown, effectively cancelling the wait.

However, to facilitate a "warm shutdown", as we intend, Ctrl+C is
perfectly allowed and we want to keep waiting for the child.  Therefore,
we perform a trick here, catching OSError, checking whether its cause
was SIGINT (errno == EINTR), and only in that case, loop to os.waitpid()
again.
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).
Vincent Driessen ba965a1dd9 Minor text change
Vincent Driessen 2d2b351f7c Change logging format.
Vincent Driessen 8678f26df0 Factor out call string.
Vincent Driessen 2ec12f1775 Fix bugje.
Vincent Driessen 1358246238 Better logging output.
Vincent Driessen 1dd73cb28d Fix comment.
Vincent Driessen d291f1dc4a Text fix.
Vincent Driessen ec4da2b3ad Add sort-by-queue flag.
Vincent Driessen cc8f05b3c6 Add __str__ to Job.
Vincent Driessen fd3831f8f2 Fix b0rken test case due to new naming conventions.
Vincent Driessen 55fd393626 Worker.find_by_key method now returns None for nonexisting workers.
Vincent Driessen 507558f6bc Avoid forked work horse to register death of its parent worker.
Vincent Driessen bd1778c610 Fix comment typo's.
Vincent Driessen 0f38cfdd84 Add rqinfo -w command, to monitor active workers.
Vincent Driessen 4ad6281641 Rewrite the ANSI color formatter a bit.
Vincent Driessen edcc012b2d Document the Queue class.
Vincent Driessen 45700fc788 Delete unused file.
Vincent Driessen c9ba66bd59 Register workers in a central set ("rq:workers").
Vincent Driessen 1f12678468 Get Worker fetch methods.
Vincent Driessen 9e8a4d15be Document methods.
Vincent Driessen 6013227f4c Remove unused property.
Vincent Driessen aebfe74630 Add polling/scaling graphs.
Vincent Driessen 15c4efd2e1 Generate less intensive work.
Vincent Driessen a905961f94 Add some sample scripts.
Vincent Driessen a029e5437b Add beginnings of a rqworker script.
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.
Vincent Driessen d761dd0280 Add BSD license, copied from git-flow.
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.
Vincent Driessen 0ff2984adf Use __slots__, for minimal memory overhead.
Vincent Driessen ced001cbb9 Update README with some project values.
Vincent Driessen 56c4445bb2 Shut up pyflakes.
Vincent Driessen b5ea5f32fe Variable renamed.
Vincent Driessen 8852859fc4 Improved the __repr__ and __str__ of Queues.
Vincent Driessen b4c1c85276 Add equality and comparison methods.
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 .
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.
Vincent Driessen 652ced2580 Add sources of inspiration.