diff options
| author | Marko Kreen | 2010-10-19 11:56:26 +0000 |
|---|---|---|
| committer | Marko Kreen | 2010-10-19 11:56:26 +0000 |
| commit | 800ab7c7ea41c9c1eb29ac97c3e70fe13991f100 (patch) | |
| tree | cacdf7cd5564f96e3a553531b8a7afc83af2b6a6 /python | |
| parent | 72c2b231db6fe55c9fee83f6ef5403b8e8321dcb (diff) | |
cascadedconsumer: missing return in get_consumer_state
Diffstat (limited to 'python')
| -rw-r--r-- | python/pgq/cascade/consumer.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/python/pgq/cascade/consumer.py b/python/pgq/cascade/consumer.py index 44a85ced..487512f7 100644 --- a/python/pgq/cascade/consumer.py +++ b/python/pgq/cascade/consumer.py @@ -96,6 +96,7 @@ class CascadedConsumer(Consumer): q = "select * from pgq_node.get_consumer_state(%s, %s)" rows = self.exec_cmd(dst_db, q, [ self.queue_name, self.consumer_name ]) state = rows[0] + return state def get_provider_db(self, state): provider_loc = state['provider_location'] |