KeyError with CoopConsumer and pgq_lazy_fetch=0 about skytools-legacy HOT 3 OPEN

Thanks for report and good analysis. Fixed in GIT with _make_event() in consumer classes.

Alternative would be to have _event_class, but that is not good unless shared somehow with walker.
So I kept things simple ATM.

Please test.

from skytools-legacy.

Hi, thanks for the quick fix.

Unfortunately there are still problems:
Traceback (most recent call last):
File "/usr/local/lib64/python2.6/site-packages/skytools/scripting.py", line 568, in run_func_safely
return func()
File "/usr/local/lib64/python2.6/site-packages/pgq/baseconsumer.py", line 257, in work
self._launch_process_batch(db, batch_id, ev_list)
File "/usr/local/lib64/python2.6/site-packages/pgq/baseconsumer.py", line 286, in _launch_process_batch
self.process_batch(db, batch_id, list)
File "/usr/local/lib64/python2.6/site-packages/pgq/baseconsumer.py", line 233, in process_batch
self.process_event(db, ev)
File "./av2te_consumer.py", line 166, in process_event
ev.tag_done()
File "/usr/local/lib64/python2.6/site-packages/pgq/consumer.py", line 23, in tag_done
self._walker.tag_event_done(self)
AttributeError: 'AV2TEConsumer' object has no attribute 'tag_event_done'

I believe the problem is due to this line:
https://github.com/markokr/skytools/blob/master/python/pgq/consumer.py#L64
which attempts to create a RetriableWalkerEvent by passing self as the walker-parameter.
However self here is a Consumer-instance so does not have a tag_event_done method.
I think you meant to pass an instance of RetriableBatchWalker instead of self?

from skytools-legacy.

we don't have walker there. The right fix is to use RetryableEvent.

I did some reorg too, to make stuff more obvious next time.

Please test.

from skytools-legacy.