Commit Graph

234 Commits

Author SHA1 Message Date
alternativshik 219f21b637 Allow non-ASCII characters in arguments
get_call_string() failed if any arguments contained non-ASCII strings.

Fixes #406
2015-02-24 11:53:47 +00:00
Selwin Ong 1005222371 Restored the ability to specify connection params in config 2015-02-23 17:28:51 +07:00
Vincent Driessen b8d425b318 Various PEP8 fixes. 2015-01-30 09:24:51 +01:00
Vincent Driessen fac2b10309 Auto-sort imports using isort. 2015-01-30 09:24:51 +01:00
Selwin Ong 105b95e9b8 Fixed an error in super call. 2015-01-26 08:37:03 +07:00
Selwin Ong de1cd8a83c Fixed test error in Python 3. 2015-01-26 08:31:58 +07:00
Selwin Ong dac0be6cc7 Added DeferredJobsRegistry to keep track of deferred jobs. 2015-01-23 17:53:27 +07:00
Selwin Ong 3e674fbe6a queue.enqueue() should set job.origin. 2015-01-23 16:33:48 +07:00
Selwin Ong 7fd2ac8ca6 Added "DEFERRED" Job status for jobs that have unsatisfied dependencies. 2015-01-23 15:16:32 +07:00
Selwin Ong 0a0a81da6d Merge pull request #463 from conslo/skip-queue
Skip queue
2015-01-12 14:33:22 +07:00
Jonathan Tushman 60c27d5a27 fixing xrange for python3 compatability 2014-12-15 10:35:19 -05:00
Jonathan Tushman 1ae5a12a81 merging master 2014-12-15 10:06:19 -05:00
Jonathan Tushman ccd41396f6 adding suspend with duration test 2014-12-15 10:04:13 -05:00
Travis Johnson 2667088b68 changed the kwarg, but forgot to change the test 2014-12-14 23:02:47 -05:00
Travis Johnson add4d625b6 Merge branch 'nvie' into skip-queue
Conflicts:
	rq/queue.py
2014-12-14 14:58:43 -05:00
Vincent Driessen cd0c3c9c1e Merge pull request #462 from conslo/worker-hash
Worker hash
2014-12-14 10:03:54 +01:00
Jonathan Tushman 82333d2ad5 triggering shutdown by setting a redis flag 2014-12-12 16:58:41 -05:00
Selwin Ong e1801c5c44 Merge pull request #453 from glaslos/job_ttl
TTL for jobs
2014-12-12 14:06:26 +07:00
Travis Johnson d4b72d330d test for skip_queue mechanics 2014-12-09 12:04:57 -05:00
Travis Johnson 6ef9177a7d 2.6 compatible set syntax 2014-12-09 11:13:56 -05:00
Travis Johnson de72f98fbe test for workers equality 2014-12-08 18:17:32 -05:00
Nic Cope 09cab7a90d Allow maximum job age to be specified when cleaning up or getting expired jobs from a registry.
This ensures that all jobs cleaned from a started registry end up in the failed queue.
2014-12-02 16:37:20 -05:00
glaslos 8a3fd91e2e renaming job.job_ttl to job.ttl 2014-11-26 10:12:52 +01:00
Selwin Ong 2091c601b1 Merge pull request #451 from conslo/depend-on-unsaved-job-ids
Depend on unsaved job ids
2014-11-26 08:33:05 +07:00
Nic Cope 8fa184b86b Ensure the FinishedJobRegistry honors an 'infinite' result_ttl of -1 2014-11-25 20:30:05 -05:00
glaslos 55c541bc59 added job ttl to queue.enqueue() 2014-11-24 14:12:51 +01:00
Travis Johnson b14f739dfe no need for that save anymore 2014-11-18 12:09:22 -05:00
Travis Johnson 82729c98dc test for id based job dependancies 2014-11-17 15:22:48 -05:00
Adam Wen cd0230cae3 make job description unicode friendly 2014-10-16 18:00:48 +08:00
zhangliyong 3d49784bcc Merge branch 'master' of github.com:nvie/rq into cli-rq-worker 2014-09-14 14:45:22 +07:00
Selwin Ong 2307bc8253 Added FinishedJobRegistry to monitor finished jobs. 2014-09-14 10:29:17 +07:00
Selwin Ong 74a9982ecb Fixed a bug where expired jobs aren't deleted from JobStartedRegistry. 2014-09-13 17:13:18 +07:00
Selwin Ong 18c6ea64ef Merge pull request #419 from selwin/registry-len
Added JobStartedRegistry.count
2014-09-12 16:01:44 +07:00
zhangliyong f9511664c8 Make flake8 happy :) 2014-09-12 14:28:41 +07:00
zhangliyong 94e494e645 Add testcase for rq worker command 2014-09-12 14:27:29 +07:00
zhangliyong 918403e371 Update test_cli 2014-09-12 11:36:55 +07:00
Selwin Ong 202be75b21 Merge pull request #415 from foxx/feature/custom-job-ids
Allow job ID to be set on enqueue/enqueue_call() - fixes #412
2014-09-10 00:42:50 +07:00
Selwin Ong c1dc30eae3 Added __len__ method to Queue. 2014-09-10 00:00:16 +07:00
Selwin Ong fae7df5aa7 Renamed StartedJobRegistry.get_job_count to StartedJobRegistry.count for consistency. 2014-09-09 23:58:35 +07:00
Selwin Ong 41ae1ce8a7 Added a registry.get_job_count(). 2014-09-09 23:54:33 +07:00
Cal Leeming 6aa2e18f88 Another unused import, oops 2014-09-09 17:47:41 +01:00
Vincent Driessen 7686785d61 Merge branch 'selwin-working-queue'
Conflicts:
	tests/test_worker.py
2014-09-08 20:37:10 +02:00
Vincent Driessen 4b7c59d68d Fix PEP8 complaints. 2014-09-08 20:29:24 +02:00
Selwin Ong 6d79082b62 Call move_expired_jobs_to_failed_queue before returning job_ids. 2014-09-08 23:04:18 +07:00
Selwin Ong dc12f8aee5 Fixed random registry failures when run on slower machines. 2014-09-08 22:54:04 +07:00
Selwin Ong 9341a4a33d Renamed WorkingQueue to StartedJobRegistry. 2014-09-08 22:46:26 +07:00
Selwin Ong 4d90cc062e Add job to WorkingQueue before execution and remove from WorkingQueue after. 2014-09-08 22:46:25 +07:00
Selwin Ong a28575088b Implemented WorkingQueue.cleanup(). 2014-09-08 22:44:54 +07:00
Selwin Ong 3dc008d090 Added WorkingQueue class. 2014-09-08 22:44:54 +07:00
Vincent Driessen 9ab46804c6 Merge pull request #417 from foxx/feature/testworker
Added test worker for unit tests - fixes #413
2014-09-08 13:15:54 +02:00