python/pgq: relaxed event handling
authorMarko Kreen <markokr@gmail.com>
Mon, 1 Jun 2009 13:32:08 +0000 (16:32 +0300)
committerMarko Kreen <markokr@gmail.com>
Mon, 1 Jun 2009 13:39:04 +0000 (16:39 +0300)
commitbe82460b0778e282336e0a73eec5b069cd59bb53
tree59f36e8063218cebff6be4be8ab00b805d1e2c74
parent52fa34d45d19fe4843b77e7ff21a4f9e93832800
python/pgq: relaxed event handling

.tag_done() call is no more required.  Events are by default in
'done' state.

In 2.x events were in 'retry' state by default, which was very bad
idea in retrospect.  Changing them to 'untagged' and still requiring
tag_done() does not seem too good either.  Original reasoning was to
detect and survive errors in scripts, but the result was only
confusion to everybody.

So instead of assuming that script may be buggy, now we assume
that script knows what it does.  And only by explicit action
can they be tagged as retry.
13 files changed:
python/londiste/playback.py
python/pgq/cascade/consumer.py
python/pgq/cascade/worker.py
python/pgq/consumer.py
python/pgq/event.py
python/pgq/remoteconsumer.py
scripts/bulk_loader.py
scripts/cube_dispatcher.py
scripts/queue_loader.py
scripts/queue_mover.py
scripts/queue_splitter.py
scripts/simple_serial_consumer.py
scripts/table_dispatcher.py