diff options
Diffstat (limited to 'python/pgq/localconsumer.py')
| -rw-r--r-- | python/pgq/localconsumer.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/python/pgq/localconsumer.py b/python/pgq/localconsumer.py index 5ba74453..ed791ece 100644 --- a/python/pgq/localconsumer.py +++ b/python/pgq/localconsumer.py @@ -13,11 +13,11 @@ import sys import os import errno import skytools -import pgq +from pgq.baseconsumer import BaseConsumer __all__ = ['LocalConsumer'] -class LocalConsumer(pgq.Consumer): +class LocalConsumer(BaseConsumer): """Consumer that applies batches sequentially in second database. Requirements: |