| 498 | } |
| 499 | |
| 500 | Status CatalogOpExecutor::SetEventProcessorStatus( |
| 501 | const TSetEventProcessorStatusRequest& req, |
| 502 | TSetEventProcessorStatusResponse* result) { |
| 503 | int attempt = 0; // Used for debug action only. |
| 504 | CatalogServiceConnection::RpcStatus rpc_status = |
| 505 | CatalogServiceConnection::DoRpcWithRetry(env_->catalogd_client_cache(), |
| 506 | *ExecEnv::GetInstance()->GetCatalogdAddress(), |
| 507 | &CatalogServiceClientWrapper::SetEventProcessorStatus, req, |
| 508 | FLAGS_catalog_client_connection_num_retries, |
| 509 | FLAGS_catalog_client_rpc_retry_interval_ms, |
| 510 | [&attempt]() { return CatalogRpcDebugFn(&attempt); }, result); |
| 511 | RETURN_IF_ERROR(rpc_status.status); |
| 512 | if (result->status.status_code != TErrorCode::OK) { |
| 513 | return StatusFromThrift(result->status); |
| 514 | } |
| 515 | return Status::OK(); |
| 516 | } |
| 517 | |
| 518 | Status CatalogOpExecutor::WaitForHmsEvent(const TWaitForHmsEventRequest& req, |
| 519 | TWaitForHmsEventResponse* resp) { |
nothing calls this directly
no test coverage detected