Commit Graph
133 Commits
Author SHA1 Message Date
Ilan Steemers 826178c463 Adds a MongoDB broker
* adds mongo broker tests
* adds mongo brokers docs

* broker info is now cached when it needs to connect to a server, to reduce traffic.
2015-09-25 20:03:39 +02:00
Ilan Steemers ef6a60478a Merge pull request #74 from Koed00/dev
Removes root imports for Django 1.9
2015-09-25 12:35:10 +02:00
Ilan Steemers b3381d6dae removes root imports for django 1.9
typo in test
2015-09-24 15:47:40 +02:00
Ilan Steemers cef48da789 removes root imports for django 1.9
Updated docs to promote submodule imports
2015-09-24 15:41:32 +02:00
Ilan Steemers 985fbb31cc tests cluster stop when already stopped 2015-09-24 11:21:28 +02:00
Ilan Steemers dc47ebef3c test for lock size in monitor 2015-09-19 17:25:02 +02:00
Ilan Steemers 7532cac93a test for lock_size in main class 2015-09-19 15:52:28 +02:00
Ilan Steemers 16c28a88e2 adds (approximate) lock_size to SQS broker
docs: added lock_size
2015-09-18 15:40:30 +02:00
Ilan Steemers a493f9cc78 Adds wait option to result() and fetch() 2015-09-18 10:57:09 +02:00
Ilan Steemers a6ad47b181 Adds lock count to monitor for orm broker 2015-09-17 18:55:29 +02:00
Ilan Steemers 1d12107524 Changed locking mechanism
* all new tasks start as timeouts. This makes the queries a lot simpler.

* In BULK mode, the bulk update for the lock was causing actual database locks.  The lock updates are now iterated.
2015-09-17 18:49:03 +02:00
Ilan Steemers 3ecd47fc7b tests orm queue admin overrides 2015-09-17 16:54:41 +02:00
Ilan Steemers 061775b3bb Adds group commands to task instances
* adds task.group_result()
* adds task.group_count()
* adds task.group_delete()
2015-09-16 15:47:39 +02:00
Ilan Steemers 1222285107 Adds --config option to qinfo command
Outputs current configuration constants
2015-09-15 21:39:38 +02:00
Ilan Steemers 548af6c4ad Tests no cache configuration 2015-09-15 20:29:09 +02:00
Ilan Steemers dbf0b20ba5 Fixes test for admin view 2015-09-15 17:14:08 +02:00
Ilan Steemers a060b3508a Moves bulk iteration to pusher 2015-09-15 14:45:06 +02:00
Ilan Steemers cefc7e0dc1 Adds test for orm queued task admin 2015-09-14 16:06:18 +02:00
Ilan Steemers 2bffcf554b Django ORM broker 2015-09-14 13:24:43 +02:00
Ilan Steemers 8543c5b328 Adds Fastack option to Disque broker 2015-09-11 17:58:16 +02:00
Ilan Steemers 3894019708 Disque now passes the double ack test 2015-09-11 15:36:46 +02:00
Ilan Steemers 4c413fc659 Prevents crash on duplicate acknowledge 2015-09-10 13:31:37 +02:00
Ilan Steemers 5195464c31 tests: sqs is not atomic 2015-09-10 11:34:35 +02:00
Ilan Steemers 0fe6c4cbde SQS only supports max 10 messages in bulk mode
* capped bulk at 10
* added tests
2015-09-09 19:34:06 +02:00
Ilan Steemers e4a5951f12 Resets SQS conf in case of test failure 2015-09-09 18:59:24 +02:00
Ilan Steemers d7ce945f03 Amazon SQS broker 2015-09-09 18:10:03 +02:00
Ilan Steemers 6d87163e61 Sets testing for Travis 2015-09-09 13:34:32 +02:00
Ilan Steemers cc178df2b1 #56 fakes setting cpu_affinity on unsupported platforms 2015-09-09 13:25:27 +02:00
Ilan Steemers 69df45ea4e queue size is not atomic on ironmq 2015-09-08 16:22:38 +02:00
Ilan Steemers 52f353fb37 random queue names for ironmq test 2015-09-08 16:11:27 +02:00
Ilan Steemers 661987b368 updated delete job test 2015-09-08 15:56:53 +02:00
Ilan Steemers 8eb1431413 Resets broker configuration in case a third party broker crashes 2015-09-08 15:50:32 +02:00
Ilan Steemers c946a16b99 changes py 2.7 import for ironmq 2015-09-08 15:38:00 +02:00
Ilan Steemers 7fb12fce49 fixes iron-mq test
purging a queue that never had a message in it raises a not found error. So we queue one message to initialize.
2015-09-08 15:19:40 +02:00
Ilan Steemers d849774c86 Adds bulk option to disque broker
adds tests
2015-09-08 14:06:38 +02:00
Ilan Steemers 0ffae4519b Adds bulk get to ironmq 2015-09-08 13:37:33 +02:00
Ilan Steemers b56cc9da8f IronMQ broker 2015-09-08 11:20:31 +02:00
Ilan Steemers f4f8af1382 Fixes backward compatibility problems with django-picklefield 2015-09-07 20:24:21 +02:00
Ilan Steemers d90db10f5e Just use local disque for testing 2015-09-06 12:28:12 +02:00
Ilan Steemers 3be488f918 Adds Tynd envs for Travis
attempt #3
2015-09-04 15:48:43 +02:00
Ilan Steemers 8340a2ae57 Adds Tynd envs for Travis 2015-09-04 15:27:10 +02:00
Ilan Steemers 3524ad2dee Adds Tynd envs for Travis
and fixes timeout tests
2015-09-04 15:16:30 +02:00
Ilan Steemers e76e65640b removes AUTH for Travis test 2015-09-04 14:53:42 +02:00
Ilan Steemers 3f75e7fa05 removed SQS and IronMQ brokers for now
Both brokers are not atomic and cause all kinds of problems during testing. Needs more time.
Meanwhile I want to release the pluggable broker backend.
2015-09-04 14:49:17 +02:00
Ilan Steemers b1f2143a3d uses disque_nodes convention 2015-09-03 12:55:49 +02:00
Ilan Steemers e22980834c Fixes connectionerror bug on 2.7 2015-09-02 20:17:44 +02:00
Ilan Steemers dfb1b03cd0 Experimenting with disque build on travis 2015-09-02 20:12:00 +02:00
Ilan Steemers b901039a44 Experimenting with disque build on travis 2015-09-02 20:08:20 +02:00
Ilan Steemers 1a61fa2821 Experimenting with disque build on travis 2015-09-02 20:04:48 +02:00
Ilan Steemers 0756fb9896 Experimenting with disque build on travis 2015-09-02 20:00:43 +02:00