Permalink
Browse files

Merge branch 'jflatow-public'

  • Loading branch information...
Ville Tuulos
Ville Tuulos committed May 6, 2011
2 parents c9ec08a + 93133dd commit 0f13a6ed06d34d099257a5cc9ad4f3cc106bf4b1
Showing with 12 additions and 0 deletions.
  1. +12 −0 lib/disco/worker/classic/worker.py
@@ -44,6 +44,12 @@ class Worker(worker.Worker):
:param map_init: initialization function for the map task.
This function is called once before the task starts.
+ .. deprecated:: 0.4
+ *map_init* has not been needed ever since
+ :func:`InputStreams <disco.worker.classic.func.InputStream>`
+ were introduced.
+ Use *map_input_stream* and/or *map_reader* instead.
+
:type map_input_stream: sequence of :func:`disco.worker.classic.func.input_stream`
:param map_input_stream: The given functions are chained together and the final resulting
:class:`disco.worker.classic.func.InputStream` object is used
@@ -90,6 +96,12 @@ class Worker(worker.Worker):
:param reduce_init: initialization function for the reduce task.
This function is called once before the task starts.
+ .. deprecated:: 0.4
+ *reduce_init* has not been needed ever since
+ :func:`InputStreams <disco.worker.classic.func.InputStream>`
+ were introduced.
+ Use *reduce_input_stream* and/or *reduce_reader* instead.
+
:type reduce_input_stream: sequence of :func:`disco.worker.classic.func.output_stream`
:param reduce_input_stream: The given functions are chained together and the last
returned :class:`disco.worker.classic.func.InputStream` object is

0 comments on commit 0f13a6e

Please sign in to comment.