summaryrefslogtreecommitdiff
path: root/scripts/cube_dispatcher.py
diff options
context:
space:
mode:
Diffstat (limited to 'scripts/cube_dispatcher.py')
-rwxr-xr-xscripts/cube_dispatcher.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/scripts/cube_dispatcher.py b/scripts/cube_dispatcher.py
index 7425ae7f..912dbe73 100755
--- a/scripts/cube_dispatcher.py
+++ b/scripts/cube_dispatcher.py
@@ -86,7 +86,7 @@ class CubeDispatcher(pgq.SerialConsumer):
inf = {
'parent': ev.extra1,
'table': tbl,
- 'key_list': ev.type.split(':')[1]
+ 'key_list': ev.extra2,
}
return inf
@@ -97,8 +97,8 @@ class CubeDispatcher(pgq.SerialConsumer):
data = skytools.db_urldecode(ev.data)
# parse tbl info
- op, keys = ev.type.split(':')
- key_list = keys.split(',')
+ op = ev.type
+ key_list = ev.extra2.split(',')
if self.keep_latest and len(key_list) == 0:
raise Exception('No pkey on table %s' % tbl)