Executor: Invoke function(input, *args, **kwargs)

eproxus · Jan 12, 2010 · c0c8a57 · c0c8a57
1 parent b233078
commit c0c8a57
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/stream.py b/stream.py
@@ -901,7 +901,7 @@ def process_job_id(input):
 			input, dupinput = itertools.tee(input)
 			id = iter(dupinput >> cut[0])
 			input = iter(input >> cut[1])
-			output = function(input)
+			output = function(input, *args, **kwargs)
 			for item in output:
 				yield next(id), item
 		self.pool = poolclass(process_job_id,