| 483 | } |
| 484 | |
| 485 | Status CatalogOpExecutor::GetLatestCompactions( |
| 486 | const TGetLatestCompactionsRequest& req, TGetLatestCompactionsResponse* result) { |
| 487 | int attempt = 0; // Used for debug action only. |
| 488 | CatalogServiceConnection::RpcStatus rpc_status = |
| 489 | CatalogServiceConnection::DoRpcWithRetry( |
| 490 | env_->catalogd_lightweight_req_client_cache(), |
| 491 | *ExecEnv::GetInstance()->GetCatalogdAddress().get(), |
| 492 | &CatalogServiceClientWrapper::GetLatestCompactions, req, |
| 493 | FLAGS_catalog_client_connection_num_retries, |
| 494 | FLAGS_catalog_client_rpc_retry_interval_ms, |
| 495 | [&attempt]() { return CatalogRpcDebugFn(&attempt); }, result); |
| 496 | RETURN_IF_ERROR(rpc_status.status); |
| 497 | return Status::OK(); |
| 498 | } |
| 499 | |
| 500 | Status CatalogOpExecutor::SetEventProcessorStatus( |
| 501 | const TSetEventProcessorStatusRequest& req, |
nothing calls this directly
no test coverage detected