| 505 | } |
| 506 | |
| 507 | Status QueryState::GetFInstanceState( |
| 508 | const TUniqueId& instance_id, FragmentInstanceState** fi_state) { |
| 509 | VLOG_FILE << "GetFInstanceState(): instance_id=" << PrintId(instance_id); |
| 510 | RETURN_IF_ERROR(WaitForPrepare()); |
| 511 | auto it = fis_map_.find(instance_id); |
| 512 | *fi_state = it != fis_map_.end() ? it->second : nullptr; |
| 513 | return Status::OK(); |
| 514 | } |
| 515 | |
| 516 | int64_t QueryState::AsyncCodegenThreadHelper(const std::string& suffix) const { |
| 517 | int64_t res = 0; |