| 2181 | } |
| 2182 | |
| 2183 | void ClientRequestState::MarkAsRetried(const TUniqueId& retried_id) { |
| 2184 | DCHECK(retry_state() == RetryState::RETRYING) |
| 2185 | << Substitute("Illegal retry state transition: $0 -> RETRYING, query_id=$2", |
| 2186 | RetryStateToString(retry_state()), PrintId(query_id())); |
| 2187 | retry_state_.Store(RetryState::RETRIED); |
| 2188 | summary_profile_->AddInfoStringRedacted( |
| 2189 | RETRY_STATUS_KEY, RetryStateToString(RetryState::RETRIED)); |
| 2190 | summary_profile_->AddInfoString("Retried Query Id", PrintId(retried_id)); |
| 2191 | UpdateExecState(ExecState::ERROR); |
| 2192 | block_until_retried_cv_.NotifyOne(); |
| 2193 | retried_id_ = make_unique<TUniqueId>(retried_id); |
| 2194 | } |
| 2195 | |
| 2196 | const string& ClientRequestState::effective_user() const { |
| 2197 | return GetEffectiveUser(query_ctx_.session); |
no test coverage detected