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

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

src/v/2/v2ex-HEAD/mapreduce/handlers.py   v2ex(Download)
    """
    MapperWorkerCallbackHandler.schedule_slice(
        self.base_path(), mapreduce_spec, self.shard_id(),
        self.slice_id() + 1, input_reader)
 
    self.refill_quotas(poll_time, processing_rate, active_shards)
    ControllerCallbackHandler.reschedule(
        self.base_path(), spec, self.serial_id() + 1)
 
  def aggregate_state(self, mapreduce_state, shard_states):
 
    KickOffJobHandler._schedule_shards(
        spec, input_readers, queue_name, self.base_path())
 
    ControllerCallbackHandler.reschedule(
        self.base_path(), spec, queue_name=queue_name, serial_id=0)

src/d/j/django-v2ex-HEAD/mapreduce/handlers.py   django-v2ex(Download)
    """
    MapperWorkerCallbackHandler.schedule_slice(
        self.base_path(), mapreduce_spec, self.shard_id(),
        self.slice_id() + 1, input_reader)
 
    self.refill_quotas(poll_time, processing_rate, active_shards)
    ControllerCallbackHandler.reschedule(
        self.base_path(), spec, self.serial_id() + 1)
 
  def aggregate_state(self, mapreduce_state, shard_states):
 
    KickOffJobHandler._schedule_shards(
        spec, input_readers, queue_name, self.base_path())
 
    ControllerCallbackHandler.reschedule(
        self.base_path(), spec, queue_name=queue_name, serial_id=0)

src/p/y/pylibs-HEAD/mapreduce/handlers.py   pylibs(Download)
    """
    MapperWorkerCallbackHandler.schedule_slice(
        self.base_path(), mapreduce_spec, self.shard_id(),
        self.slice_id() + 1, input_reader)
 
        "processing_rate") or model._DEFAULT_PROCESSING_RATE_PER_SEC)
    self.refill_quotas(poll_time, processing_rate, active_shards)
    ControllerCallbackHandler.schedule(self.base_path(), spec)
 
  def aggregate_state(self, mapreduce_state, shard_states):