Skip to content

Commit

Permalink
Fixed build errors
Browse files Browse the repository at this point in the history
  • Loading branch information
GrigoriyPA committed Feb 27, 2024
1 parent e015d1d commit 76a5986
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 3 deletions.
2 changes: 1 addition & 1 deletion ydb/core/fq/libs/compute/ydb/base_status_updater_actor.h
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@ namespace NFq {
template<typename TDerived>
class TBaseStatusUpdaterActor : public TBaseComputeActor<TDerived> {
public:
using TBase = NActors::TActorBootstrapped<TDerived>;
using TBase = TBaseComputeActor<TDerived>;

TBaseStatusUpdaterActor(const NConfig::TCommonConfig& commonConfig, const ::NYql::NCommon::TServiceCounters& queryCounters, const TString& stepName)
: TBase(queryCounters, stepName)
Expand Down
6 changes: 4 additions & 2 deletions ydb/core/fq/libs/compute/ydb/stopper_actor.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -122,9 +122,11 @@ class TStopperActor : public TBaseStatusUpdaterActor<TStopperActor> {
return;
}

LOG_I("Operation successfully fetched, Status: " << response.Status << ", StatusCode: " << NYql::NDqProto::StatusIds::StatusCode_Name(response.StatusCode) << " Issues: " << response.Issues.ToOneLineString());
auto statusCode = NYql::NDq::YdbStatusToDqStatus(response.StatusCode);
LOG_I("Operation successfully fetched, Status: " << response.Status << ", StatusCode: " << NYql::NDqProto::StatusIds::StatusCode_Name(statusCode) << " Issues: " << response.Issues.ToOneLineString());

OnPingRequestStart();
Fq::Private::PingTaskRequest pingTaskRequest = GetPingTaskRequest(FederatedQuery::QueryMeta::ABORTING_BY_USER, NYql::NDq::YdbStatusToDqStatus(response.StatusCode), response.Issues, response.QueryStats);
Fq::Private::PingTaskRequest pingTaskRequest = GetPingTaskRequest(FederatedQuery::QueryMeta::ABORTING_BY_USER, statusCode, response.Issues, response.QueryStats);
Send(Pinger, new TEvents::TEvForwardPingRequest(pingTaskRequest));
}

Expand Down

0 comments on commit 76a5986

Please sign in to comment.