@@ -91,7 +91,10 @@ def reduce(*cmd, **kwargs):
91
91
try :
92
92
exec code in {}, globals_
93
93
except Exception , e :
94
- return {'error' : {'id' : 'reduce_compilation_error' , 'reason' : e .args [0 ]}}
94
+ return {'error' : {
95
+ 'id' : 'reduce_compilation_error' ,
96
+ 'reason' : e .args [0 ]
97
+ }}
95
98
err = {'error' : {
96
99
'id' : 'reduce_compilation_error' ,
97
100
'reason' : 'string must eval to a function (ex: "def(doc): return 1")'
@@ -103,18 +106,18 @@ def reduce(*cmd, **kwargs):
103
106
return err
104
107
105
108
results = []
106
- keys ,vals = zip (* args )
107
- if (function .func_code .co_argcount == 3 ):
108
- rereduce = kwargs ['rereduce' ] if kwargs .has_key ('rereduce' ) else False
109
- results = function (keys , vals , rereduce )
109
+ keys , vals = zip (* args )
110
+ if function .func_code .co_argcount == 3 :
111
+ results = function (keys , vals , kwargs .get ('rereduce' , False ))
110
112
else :
111
113
results = function (keys , vals )
112
114
return [True , [results ]]
113
115
114
116
def rereduce (* cmd ):
115
117
reduce (cmd , rereduce = True )
116
118
117
- handlers = {'reset' : reset , 'add_fun' : add_fun , 'map_doc' : map_doc , 'reduce' : reduce , 'rereduce' : rereduce }
119
+ handlers = {'reset' : reset , 'add_fun' : add_fun , 'map_doc' : map_doc ,
120
+ 'reduce' : reduce , 'rereduce' : rereduce }
118
121
119
122
try :
120
123
while True :
0 commit comments