def __init__(self, rate_log_interval, input_item_limit,<EOL>cleanup_tmp_files, tmp_dir_path, assert_single_source,<EOL>output_chunk_max_count, output_max_clean_visible_bytes,<EOL>reader, incremental_transforms, batch_transforms,<EOL>post_batch_incremental_transforms, writers):
self.rate_log_interval = rate_log_interval<EOL>self.input_item_limit = input_item_limit<EOL>self.cleanup_tmp_files = cleanup_tmp_files<EOL>self.tmp_dir_path = tmp_dir_path<EOL>self.assert_single_source = assert_single_source<EOL>self.output_chunk_max_count = output_chunk_max_count<EOL>self.output_max_clean_visible_bytes = output_max_clean_visible_bytes<EOL>self.reader = reader<EOL>self.incremental_transforms = incremental_transforms<EOL>self.batch_transforms = batch_transforms<EOL>self.pbi_stages = post_batch_incremental_transforms<EOL>self.writers = writers<EOL>self.t_chunk = None<EOL>self.context = dict(<EOL>i_str=None,<EOL>data=None,<EOL>)<EOL>self.work_unit = None<EOL>
Create a new pipeline object.

        .. todo:: make this callable with just the lists of stages
                  and give sane (language-level) defaults for the rest

        :param int rate_log_interval: print progress every time this
          many input items have been processed
        :param int input_item_limit: stop after this many items
        :param bool cleanup_tmp_files: delete `tmp_dir_path` after
          execution if true
        :param str tmp_dir_path: path for intermediate files
        :param bool assert_single_source: require all items to have
          the same source value if true
        :param int output_chunk_max_count: restart output after
          writing this many items
        :param int output_max_clean_visible_bytes: restart output after
          writing this much content
        :param callable reader: reader stage object
        :param incremental_transforms: single-item transformation stages
        :paramtype incremental_transforms: list of callable
        :param batch_transforms: chunk-file transformation stages
        :paramtype batch_transforms: list of callable
        :param post_batch_incremental_transforms: single-item transformation
          stages
        :paramtype post_batch_incremental_transforms: list of callable
        :param writers: output stages
        :paramtype writers: list of callable