Commit 663a29c5 authored by ale's avatar ale
Browse files

use the proper verb to access the 'in_cns' set

parent 9e38af68
...@@ -89,7 +89,7 @@ class Accounting(object): ...@@ -89,7 +89,7 @@ class Accounting(object):
while True: while True:
try: try:
local_pipe.watch('in_cns') local_pipe.watch('in_cns')
input_cns = local_pipe.get('in_cns') input_cns = local_pipe.smembers('in_cns')
local_pipe.delete('in_cns') local_pipe.delete('in_cns')
break break
except redis.WatchError: except redis.WatchError:
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment