176 if fx == 'INIT': |
176 if fx == 'INIT': |
177 ret = self.__initClientService(fn, *data) |
177 ret = self.__initClientService(fn, *data) |
178 elif fx.startswith("batch_"): |
178 elif fx.startswith("batch_"): |
179 callback = self.batchServices.get(fx) |
179 callback = self.batchServices.get(fx) |
180 if callback: |
180 if callback: |
181 try: |
181 callback(data, self.__send, fx, self.__cancelled, |
182 callback(data, self.__send, fx, self.__cancelled, |
182 maxProcesses=self.__maxProcs) |
183 maxProcesses=self.__maxProcs) |
|
184 except TypeError: |
|
185 # for backward compatibility |
|
186 callback(data, self.__send, fx, self.__cancelled) |
|
187 ret = "__DONE__" |
183 ret = "__DONE__" |
188 else: |
184 else: |
189 ret = 'Unknown batch service.' |
185 ret = 'Unknown batch service.' |
190 else: |
186 else: |
191 callback = self.services.get(fx) |
187 callback = self.services.get(fx) |