Searched refs:current_attempt (Results 1 – 2 of 2) sorted by relevance
525 def current_attempt(self): member in Pipeline602 stage._current_attempt = pipeline_record.current_attempt2105 if pipeline_record.current_attempt != attempt:2109 pipeline_record.current_attempt)2112 if pipeline_record.current_attempt >= pipeline_record.max_attempts:2125 pipeline_record.current_attempt, pipeline_record.next_retry_time))2567 (params['backoff_factor'] ** pipeline_record.current_attempt))2570 pipeline_record.current_attempt += 12574 if pipeline_record.current_attempt >= pipeline_record.max_attempts:2581 pipeline_record.current_attempt, root_pipeline_key.name())[all …]
81 current_attempt = db.IntegerProperty(default=0, indexed=False) variable in _PipelineRecord