diff options
Diffstat (limited to 'python/pgq/event.py')
-rw-r--r-- | python/pgq/event.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/python/pgq/event.py b/python/pgq/event.py index 93745035..39735507 100644 --- a/python/pgq/event.py +++ b/python/pgq/event.py @@ -19,6 +19,7 @@ _fldmap = { 'ev_extra2': 'ev_extra2', 'ev_extra3': 'ev_extra3', 'ev_extra4': 'ev_extra4', + 'ev_retry': 'ev_retry', 'id': 'ev_id', 'txid': 'ev_txid', @@ -29,6 +30,7 @@ _fldmap = { 'extra2': 'ev_extra2', 'extra3': 'ev_extra3', 'extra4': 'ev_extra4', + 'retry': 'ev_retry', } class Event(object): @@ -42,7 +44,7 @@ class Event(object): def __init__(self, queue_name, row): self._event_row = row - self._status = EV_UNTAGGED + self._status = EV_DONE self.retry_time = 60 self.queue_name = queue_name |