ghettoq
ghettoq copied to clipboard
ask
Ghetto Queue support for Celery/Carrot (discontinued; Use Kombu instead)
With 100000 messages processing queue entries becomes timeconsuming (roughly 2 sec per pop() du to filesorting and mysql picking the visible index to use). This is not intended as a...
The couch backend completely ignores user / password config, and doesn't support authentication with couchdb. You can authenticate like http://user:pass@couhhost:port/ so this should be an easy fix.
If I run ghettoq against the default db, everything works fine but if I setup a DB Router to direct all traffic for this app to a separate db, it...
So there's no way that the connection will be closed. I believe it should be: ``` def close(self): if self.connection is not None: self.connection.disconnect() ```
Would be awesome-possum if there was a database backend that is not Django-dependent. I would suggest using something like SQLAlchemy.
In the `establish_connection` method of `MultiBackend`, it monkey patches the connection's `drain_events` method: ``` def establish_connection(self): conninfo = self.connection conn = Connection(self.type, host=conninfo.hostname, user=conninfo.userid, password=conninfo.password, database=conninfo.virtual_host, port=conninfo.port) conn.drain_events = self.drain_events...
django-admin test fails with ghettoq (0.4) in INSTALLED_APPS with django 1.2. Traceback (most recent call last): File "/usr/local/bin/django-admin.py", line 5, in management.execute_from_command_line() File "/usr/local/lib/python2.6/dist-packages/django/core/management/__init__.py", line 429, in execute_from_command_line utility.execute() File...
in line 32 of pyredis.py please change: please do: return Redis(host=self.host, port=int(self.port),..... - ie. cast port to int() - if someone reads celeryconfig from ini - then port will be...
Have to make this feature belong to the backend.
