Commit Graph

270 Commits

Author SHA1 Message Date
Vincent Driessen 1f64157c38 Broke down tests into multiple files. 2012-01-28 07:58:40 +01:00
Vincent Driessen 210477c2ab Throw DequeueError when reading unprocessable data from queue. 2012-01-27 15:17:14 +01:00
Vincent Driessen aa2c9e85eb Use 'busy' and 'idle' to replace the unicode symbols. 2012-01-27 11:38:55 +01:00
Vincent Driessen cce85c11c5 Fix missing import statement. 2012-01-27 11:38:27 +01:00
Vincent Driessen 62ae299114 Fix mathematical meaning of the < operator.
This is used for alphabetical queue ordering.
2012-01-27 11:37:46 +01:00
Vincent Driessen aa030e0e36 Fix syntax error inside shell script. 2012-01-25 15:24:58 +01:00
Vincent Driessen e992d65a30 Add RPM dependencies. 2012-01-25 10:46:11 +01:00
Vincent Driessen a111db13fd Allow users to specify the import path manually, if the default (current
working directory) is undesired.
2011-12-13 17:09:58 +01:00
Vincent Driessen 2ac6c1faa3 Allow includes from the local directory by default.
Will build in a flag in the future to be able to disallow this.
2011-12-12 10:44:52 +01:00
Vincent Driessen 7be878aed7 Allow specification of DB.
(And fix the worker actually being able to connect to a different
database.)
2011-11-28 21:02:42 +01:00
Vincent Driessen 5c6f002878 Silently pass when trying to kill child that is already dead.
This fixes #16.
2011-11-28 15:15:18 +01:00
Vincent Driessen 039a132374 Add ellipsis, to indicate we're waiting here. 2011-11-28 15:04:42 +01:00
Vincent Driessen b27786332c Also use argparse for the rqworker. 2011-11-28 15:04:24 +01:00
Vincent Driessen 903f1b9f46 Fix command description. 2011-11-28 15:03:49 +01:00
Vincent Driessen 27ddde2008 Make procname a hard dependency. 2011-11-28 14:17:42 +01:00
Vincent Driessen 2ff383162c Fix bug #15. 2011-11-28 14:14:11 +01:00
Vincent Driessen da228dd76c Fix casing. 2011-11-28 14:07:12 +01:00
Vincent Driessen 2300338893 Update dependencies accordingly 2011-11-28 14:07:04 +01:00
Vincent Driessen 1dba21f176 Add --host and --port options to specify what Redis to use. 2011-11-28 13:58:13 +01:00
Vincent Driessen 56d05c3509 Replace optparse with the more flexible argparse.
We now have real subcommands.
2011-11-28 13:56:38 +01:00
Vincent Driessen c820ba24fa Move to Alpha stage. 2011-11-28 12:11:09 +01:00
Vincent Driessen 66775b7012 Put the version number somewhere central. 2011-11-28 12:10:15 +01:00
Vincent Driessen e49e0135bc Update Trove classifiers. 2011-11-28 12:09:36 +01:00
Vincent Driessen bf6347e78e Inverse the --graph option (and rename to --raw). 2011-11-28 11:41:11 +01:00
Vincent Driessen b1f571e920 Move function up. 2011-11-28 11:40:45 +01:00
Vincent Driessen 2c72d94ebd Run class initializations only once. 2011-11-27 08:00:41 +01:00
Vincent Driessen 373aeb214e Getting the facts right here. 2011-11-26 13:46:22 +01:00
Vincent Driessen 767ad519c2 Fix code 2011-11-26 13:10:04 +01:00
Vincent Driessen 068db4cb35 Shut up logbook during tests. 2011-11-26 09:32:19 +01:00
Vincent Driessen 4eb8425acc Copy-paste README doc from gh-pages. 2011-11-26 09:31:59 +01:00
Vincent Driessen aecb0a1bf0 Simplify calling .work() or .work(burst=True). 2011-11-26 09:31:14 +01:00
Vincent Driessen 636b6690d6 Add the signal name to the debug message. 2011-11-25 01:11:52 +01:00
Vincent Driessen a154ef0bd9 Remove comment.
This ain't the right way to terminate when blocking by pop.
2011-11-25 01:11:14 +01:00
Vincent Driessen 253f1752b8 Shorter logbook format on standard output, for readability.
Still, the original output can be seen using the `--verbose` flag.
2011-11-25 00:46:19 +01:00
Vincent Driessen 62949c9adb Extra debug output. 2011-11-25 00:45:26 +01:00
Vincent Driessen dde3ea8ef7 Take down horse process when the worker is terminated. 2011-11-25 00:45:03 +01:00
Vincent Driessen 4ac243b3e8 Print what signal was received in a debug statement. 2011-11-25 00:44:18 +01:00
Vincent Driessen 7769d9875f Perform a warm shutdown on SIGTERM, too.
Just like with Ctrl+C (SIGINT), shutdown warmly at first when kill'ed
(SIGTERM).
2011-11-25 00:43:32 +01:00
Vincent Driessen 3ecda16665 Fix output. 2011-11-25 00:39:36 +01:00
Vincent Driessen 7841e23cc4 Add procname dependency.
Eventually, this will be optional, but for now, include it as there
actually *is* a dependency.
2011-11-24 16:57:51 +01:00
Vincent Driessen 213ac73e19 Remove blinker dependency. 2011-11-24 16:57:01 +01:00
Vincent Driessen 5dba007222 Add script to calculate project size.
This will help keep the "lightweight" claim up.
2011-11-24 16:56:14 +01:00
Vincent Driessen 88cbaa1df9 Slight code reshuffle + added some comments on the construction. 2011-11-24 16:21:52 +01:00
Vincent Driessen 7cba8449d9 Add comments. 2011-11-24 15:52:15 +01:00
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.
2011-11-24 15:42:01 +01:00
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).
2011-11-24 14:26:21 +01:00
Vincent Driessen ba965a1dd9 Minor text change 2011-11-22 07:36:46 +01:00
Vincent Driessen 2d2b351f7c Change logging format. 2011-11-21 22:41:50 +01:00
Vincent Driessen 8678f26df0 Factor out call string. 2011-11-21 20:52:05 +01:00
Vincent Driessen 2ec12f1775 Fix bugje. 2011-11-21 17:12:47 +01:00