diff options
| author | Marko Kreen | 2008-04-23 15:07:04 +0000 |
|---|---|---|
| committer | Marko Kreen | 2008-04-23 15:07:04 +0000 |
| commit | 43b07b728ad3c73a1ba093caec3b36707350eae7 (patch) | |
| tree | 0db460f699b9fb283bf6474e3007c2590df5d9b5 /python/pgq/rawconsumer.py | |
| parent | fbe997fbdae1fe568042255a32c373e1ff9528b0 (diff) | |
python/pgq: more set work
- use worker_name == node_name
- make status command show lag
- pass root tick_time downstream
Diffstat (limited to 'python/pgq/rawconsumer.py')
| -rw-r--r-- | python/pgq/rawconsumer.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/python/pgq/rawconsumer.py b/python/pgq/rawconsumer.py index 1ab452fc..a43b86b7 100644 --- a/python/pgq/rawconsumer.py +++ b/python/pgq/rawconsumer.py @@ -23,11 +23,12 @@ class RawQueue: if not self.batch_id: return self.batch_id - q = "select tick_id, prev_tick_id from pgq.get_batch_info(%s)" + q = "select tick_id, prev_tick_id, batch_end from pgq.get_batch_info(%s)" curs.execute(q, [self.batch_id]) inf = curs.dictfetchone() self.cur_tick = inf['tick_id'] self.prev_tick = inf['prev_tick_id'] + self.tick_time = inf['batch_end'] return self.batch_id |