Home
last modified time | relevance | path

Searched refs:shard_id (Results 1 – 15 of 15) sorted by relevance

/external/chromium-trace/catapult/third_party/mapreduce/mapreduce/
Dhandlers.py146 shard_id = self.request.headers[util._MR_SHARD_ID_TASK_HEADER]
149 model.ShardState.get_key_by_shard_id(shard_id),
178 tstate.shard_id)
183 "execution. Dropping this task.", tstate.shard_id)
192 tstate.shard_id,
202 shard_state.shard_id)
210 tstate.shard_id, tstate.slice_id, shard_state.slice_id)
218 tstate.shard_id, tstate.slice_id, shard_state.slice_id)
229 "Will try again in %s seconds", tstate.shard_id, tstate.slice_id,
243 "%s. Will try again later.", tstate.shard_id, tstate.slice_id,
[all …]
Dmodel.py742 shard_id, argument
767 self.shard_id = shard_id
806 "shard_id": self.shard_id,
1046 shard_id = property(get_shard_id) variable in ShardState
1067 def get_key_by_shard_id(cls, shard_id): argument
1076 return db.Key.from_path(cls.kind(), shard_id)
1079 def get_by_shard_id(cls, shard_id): argument
1088 return cls.get_by_key_name(shard_id)
1145 shard_id = cls.shard_id_from_number(mapreduce_state.key().name(), i)
1146 keys.append(cls.get_key_by_shard_id(shard_id))
[all …]
Dmap_job_context.py44 self.id = shard_state.shard_id
Dcontext.py419 self.shard_id = shard_state.get_shard_id()
422 self.shard_id = None
Dstatus.py386 "shard_id": shard.shard_id,
Dshuffler.py152 ctx.shard_id + "-" + str(int(time.time())))
/external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/integration/kinesis/
Dtest_kinesis.py53 shard_id = response['StreamDescription']['Shards'][0]['ShardId']
73 response = kinesis.get_shard_iterator('test', shard_id, 'TRIM_HORIZON')
/external/autotest/scheduler/
Drdb_hosts.py110 self.shard_id = host.shard_id
Dscheduler_models_unittest.py307 self.assertIsNone(hqe.job.shard_id)
310 self.assertEquals(hqe.job.shard_id, 3)
Drdb.py466 [host.shard_id for host in hosts])
Dmonitor_db.py889 if entry.job.shard_id is not None and not server_utils.is_shard():
891 entry.job.shard_id, entry)
Dscheduler_models.py645 if self.job.shard_id is not None:
/external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/kinesis/
Dlayer1.py337 def get_shard_iterator(self, stream_name, shard_id, shard_iterator_type, argument
416 'ShardId': shard_id,
/external/autotest/frontend/afe/
Dsite_rpc_interface_unittest.py774 shard_id = site_rpc_interface.add_shard(
779 shard = models.Shard.objects.get(pk=shard_id)
Dmodels.py1333 if self.shard_id and self.shard_id != shard.id:
1336 'from shard %s.' % (self.id, self.shard_id, updated_serialized,