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

All Samples(20)  |  Call(16)  |  Derive(4)  |  Import(0)

src/8/0/8-bits-HEAD/appengine-mapreduce/python/test/mapreduce/input_readers_test.py   8-bits(Download)
 
    query_range = input_readers.DatastoreInputReader(
        ENTITY_KIND, key_ranges=kranges, ns_range=None, batch_size=50)
 
    entities = []
 
    query_range = input_readers.DatastoreInputReader(
        ENTITY_KIND, key_ranges=None, ns_range=ns_range, batch_size=50)
 
    objects = []
 
    reader = input_readers.DatastoreInputReader(
        ENTITY_KIND,
        key_ranges=[
          key_range.KeyRange(

src/a/p/appengine-mapreduce-HEAD/python/test/mapreduce/input_readers_test.py   appengine-mapreduce(Download)
 
    query_range = input_readers.DatastoreInputReader(
        ENTITY_KIND, kranges, 50)
 
    entities = []

src/8/0/8-bits-HEAD/appengine-mapreduce/python/test/mapreduce/handlers_test.py   8-bits(Download)
class InputReader(input_readers.DatastoreInputReader):
  """Test input reader which records number of yields."""
 
  yields = 0
 
class FixedShardSizeInputReader(input_readers.DatastoreInputReader):
  """Test reader which truncates the list of readers to specified size."""
  readers_size = 3
 
  @classmethod
  def testScheduleSlice(self):
    """Test _schedule_slice method."""
    input_reader = input_readers.DatastoreInputReader(
        ENTITY_KIND,
        [key_range.KeyRange(key_start=self.key(75),
  def testScheduleSlice_Eta(self):
    """Test _schedule_slice method."""
    eta = datetime.datetime.utcnow() + datetime.timedelta(hours=1)
    input_reader = input_readers.DatastoreInputReader(
        ENTITY_KIND,
  def testScheduleSlice_Countdown(self):
    """Test _schedule_slice method."""
    countdown = 60 * 60
    input_reader = input_readers.DatastoreInputReader(
        ENTITY_KIND,

src/a/p/appengine-mapreduce-HEAD/python/test/mapreduce/handlers_test.py   appengine-mapreduce(Download)
class InputReader(input_readers.DatastoreInputReader):
  """Test input reader which records number of yields."""
 
  yields = 0
 
class FixedShardSizeInputReader(input_readers.DatastoreInputReader):
  """Test rider which trucates the list of readers to specified size."""
  readers_size = 3
 
  @classmethod
  def testScheduleSlice(self):
    """Test schedule_slice method."""
    input_reader = input_readers.DatastoreInputReader(
        ENTITY_KIND,
        [key_range.KeyRange(key_start=self.key(75),
  def testScheduleSlice_Eta(self):
    """Test schedule_slice method."""
    eta = datetime.datetime.utcnow() + datetime.timedelta(hours=1)
    input_reader = input_readers.DatastoreInputReader(
        ENTITY_KIND,
  def testScheduleSlice_Countdown(self):
    """Test schedule_slice method."""
    countdown = 60 * 60
    input_reader = input_readers.DatastoreInputReader(
        ENTITY_KIND,