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

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

src/8/0/8-bits-HEAD/appengine-mapreduce/python/src/mapreduce/mapreduce_pipeline.py   8-bits(Download)
        yield (key, values)
      else:
        yield input_readers.ALLOW_CHECKPOINT
 
  @staticmethod

src/8/0/8-bits-HEAD/appengine-mapreduce/python/src/mapreduce/handlers.py   8-bits(Download)
      True if scan should be continued, False if scan should be aborted.
    """
    if data is not input_readers.ALLOW_CHECKPOINT:
      ctx.counters.increment(context.COUNTER_MAPPER_CALLS)
 

src/e/v/EVE-Prosper-HEAD/Scraps/old_dbinit/mapreduce/mapreduce_pipeline.py   EVE-Prosper(Download)
        yield (key, values)
      else:
        yield input_readers.ALLOW_CHECKPOINT
 
  def to_json(self):

src/r/p/RPI-Directory-HEAD/appengine/mapreduce/mapreduce_pipeline.py   RPI-Directory(Download)
        yield (key, values)
      else:
        yield input_readers.ALLOW_CHECKPOINT
 
  @staticmethod

src/e/v/EVE-Prosper-HEAD/Scraps/old_dbinit/mapreduce/handlers.py   EVE-Prosper(Download)
      True if scan should be continued, False if scan should be aborted.
    """
    if data is not input_readers.ALLOW_CHECKPOINT:
      ctx.counters.increment(context.COUNTER_MAPPER_CALLS)
 

src/r/p/RPI-Directory-HEAD/appengine/mapreduce/handlers.py   RPI-Directory(Download)
      True if scan should be continued, False if scan should be aborted.
    """
    if data is not input_readers.ALLOW_CHECKPOINT:
      ctx.counters.increment(context.COUNTER_MAPPER_CALLS)
 

src/g/o/GoogleAppEngineMapReduce-1.9.0.0/mapreduce/handlers.py   GoogleAppEngineMapReduce(Download)
      True if scan should be continued, False if scan should be stopped.
    """
    if data is not input_readers.ALLOW_CHECKPOINT:
      self.slice_context.incr(context.COUNTER_MAPPER_CALLS)
 

src/8/0/8-bits-HEAD/appengine-mapreduce/python/test/mapreduce/input_readers_test.py   8-bits(Download)
        if namespace in ["B", "C", "D"]:
          if i == 0:
            expected_objects.append(input_readers.ALLOW_CHECKPOINT)
          expected_objects.append(entity)
          expected_entities.append(entity)
    for o in query_range:
      objects.append(o)
      if o is not input_readers.ALLOW_CHECKPOINT:
        entities.append(o)
 
    for ns in ["b", "g", "happy", "helloworld", "r", "s", "t"]:
      namespace_manager.set_namespace(ns)
      expected_objects.add(input_readers.ALLOW_CHECKPOINT)
      expected_objects.add(datastore.Put(datastore.Entity(self.kind_id)))
    namespace_manager.set_namespace(None)
    def AddUnappliedEntities(*args):
      namespace_manager.set_namespace("a")
      expected_objects.add(input_readers.ALLOW_CHECKPOINT)
      expected_objects.add(datastore.Put(
        datastore.Entity(self.kind_id, name="a")))
 
      namespace_manager.set_namespace("d")
      expected_objects.add(input_readers.ALLOW_CHECKPOINT)

src/8/0/8-bits-HEAD/appengine-mapreduce/python/test/mapreduce/handlers_test.py   8-bits(Download)
  def testLongProcessDataWithAllowCheckpoint(self):
    """Tests that process_data works with input_readers.ALLOW_CHECKPOINT."""
    self.handler._start_time = 0
    self.assertFalse(self.handler.process_data(input_readers.ALLOW_CHECKPOINT,
                                               None,