Searched defs:shard_state (Results 1 – 5 of 5) sorted by relevance
| /external/chromium-trace/catapult/third_party/mapreduce/mapreduce/ |
| D | handlers.py | 157 def _try_acquire_lease(self, shard_state, tstate): argument
290 def _has_old_request_ended(self, shard_state): argument
316 def _wait_time(self, shard_state, secs, now=datetime.datetime.now): argument
335 def _try_free_lease(self, shard_state, slice_retry=False): argument
528 def __return(self, shard_state, tstate, task_directive): argument
536 shard_state, argument
650 def _set_state(self, shard_state, tstate, task_directive): argument
696 def _save_state_and_schedule_next(self, shard_state, tstate, task_directive): argument
788 def _attempt_slice_recovery(self, shard_state, tstate): argument
828 def _attempt_shard_retry(self, shard_state, tstate): argument
[all …]
|
| D | map_job_context.py | 27 def __init__(self, job_context, shard_state): argument
75 def __init__(self, shard_context, shard_state, tstate): argument
|
| D | output_writers.py | 199 def finalize(self, ctx, shard_state): argument
636 def _get_filename(cls, shard_state): argument
777 def finalize(self, ctx, shard_state): argument
1034 def finalize(self, ctx, shard_state): argument
1100 def finalize(self, ctx, shard_state): argument
|
| D | context.py | 350 def __init__(self, shard_state): argument
397 def __init__(self, mapreduce_spec, shard_state, task_retry_count=0): argument
|
| D | shuffler.py | 502 def finalize(self, ctx, shard_state): argument
|