Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(11)  |  Call(11)  |  Derive(0)  |  Import(0)

src/8/0/8-bits-HEAD/appengine-mapreduce/python/src/mapreduce/mapper_pipeline.py   8-bits(Download)
        output_writer_spec=output_writer_spec,
        )
    self.fill(self.outputs.job_id, mapreduce_id)
    self.set_status(console_url="%s/detail?job_id=%s" % (
        (base_handler._DEFAULT_BASE_PATH, mapreduce_id)))
      files = output_writer_class.get_filenames(mapreduce_state)
 
    self.fill(self.outputs.counters, mapreduce_state.counters_map.to_dict())
    self.complete(files)
 

src/e/v/EVE-Prosper-HEAD/Scraps/old_dbinit/mapreduce/mapper_pipeline.py   EVE-Prosper(Download)
        output_writer_spec=output_writer_spec,
        )
    self.fill(self.outputs.job_id, mapreduce_id)
    self.set_status(console_url="%s/detail?job_id=%s" % (
        (base_handler._DEFAULT_BASE_PATH, mapreduce_id)))
      files = output_writer_class.get_filenames(mapreduce_state)
 
    self.fill(self.outputs.counters, mapreduce_state.counters_map.to_dict())
    self.complete(files)
 

src/r/p/RPI-Directory-HEAD/appengine/mapreduce/mapper_pipeline.py   RPI-Directory(Download)
        output_writer_spec=output_writer_spec,
        )
    self.fill(self.outputs.job_id, mapreduce_id)
    self.set_status(console_url="%s/detail?job_id=%s" % (
        (base_handler._DEFAULT_BASE_PATH, mapreduce_id)))
      files = output_writer_class.get_filenames(mapreduce_state)
 
    self.fill(self.outputs.counters, mapreduce_state.counters_map.to_dict())
    self.complete(files)
 

src/8/0/8-bits-HEAD/appengine-mapreduce/python/src/mapreduce/shuffler.py   8-bits(Download)
          _blobinfo_uploaded_filename=blob_file_name)
      output_files.append(file_name)
    self.fill(self.outputs._output_files, output_files)
    files.shuffler.shuffle("%s-%s" % (job_name, int(time.time())),
                           input_files,

src/m/o/MOL-HEAD/app/mapreduce/mapper_pipeline.py   MOL(Download)
        output_writer_spec=output_writer_spec,
        )
    self.fill(self.outputs.job_id, mapreduce_id)
    self.set_status(console_url="%s/detail?job_id=%s" % (
        (base_handler._DEFAULT_BASE_PATH, mapreduce_id)))

src/d/a/Darwin-Core-Engine-HEAD/lib/appengine-mapreduce/mapper_pipeline.py   Darwin-Core-Engine(Download)
        output_writer_spec=output_writer_spec,
        )
    self.fill(self.outputs.job_id, mapreduce_id)
    self.set_status(console_url="%s/detail?job_id=%s" % (
        (base_handler._DEFAULT_BASE_PATH, mapreduce_id)))

src/e/v/EVE-Prosper-HEAD/Scraps/old_dbinit/mapreduce/shuffler.py   EVE-Prosper(Download)
          _blobinfo_uploaded_filename=blob_file_name)
      output_files.append(file_name)
    self.fill(self.outputs._output_files, output_files)
    files.shuffler.shuffle("%s-%s" % (job_name, int(time.time())),
                           input_files,

src/r/p/RPI-Directory-HEAD/appengine/mapreduce/shuffler.py   RPI-Directory(Download)
          _blobinfo_uploaded_filename=blob_file_name)
      output_files.append(file_name)
    self.fill(self.outputs._output_files, output_files)
    files.shuffler.shuffle("%s-%s" % (job_name, int(time.time())),
                           input_files,