diff options
| author | galaxycrab <UgnineSirdis@ydb.tech> | 2022-09-04 19:03:20 +0300 |
|---|---|---|
| committer | galaxycrab <UgnineSirdis@ydb.tech> | 2022-09-04 19:03:20 +0300 |
| commit | e2440732d88b0eed7b1406c59de5d4f297d7ff0f (patch) | |
| tree | 7ee4205a333796353bfe87bb8adc21b1052c64f3 | |
| parent | 23146676c917cdad8a9900565999b3361cb6c9b9 (diff) | |
| download | ydb-e2440732d88b0eed7b1406c59de5d4f297d7ff0f.tar.gz | |
Fix getting oauth token error handling in ybase tool
| -rw-r--r-- | ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h b/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h index 9d7b4a7d2e1..d55a9a4a600 100644 --- a/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h +++ b/ydb/library/yql/dq/actors/compute/dq_compute_actor_impl.h @@ -199,7 +199,7 @@ protected: IDqAsyncIoFactory::TPtr asyncIoFactory, const NKikimr::NMiniKQL::IFunctionRegistry* functionRegistry, const TComputeRuntimeSettings& settings, const TComputeMemoryLimits& memoryLimits, - const ::NMonitoring::TDynamicCounterPtr& taskCounters = nullptr, + const ::NMonitoring::TDynamicCounterPtr& taskCounters = nullptr, NWilson::TTraceId traceId = {}) : ExecuterId(executerId) , TxId(txId) @@ -371,7 +371,7 @@ protected: void ProcessOutputsImpl(ERunStatus status) { ProcessOutputsState.LastRunStatus = status; - CA_LOG_T("ProcessOutputsState.Inflight: " << ProcessOutputsState.Inflight ); + CA_LOG_T("ProcessOutputsState.Inflight: " << ProcessOutputsState.Inflight); if (ProcessOutputsState.Inflight == 0) { ProcessOutputsState = TProcessOutputsState(); } @@ -1133,7 +1133,7 @@ protected: this->TerminateSources(issues, success); if (ev->Sender != ExecuterId) { - + if (ComputeActorSpan) { ComputeActorSpan.End(); } @@ -1803,7 +1803,7 @@ protected: if (ComputeActorSpan) { ComputeActorSpan.End(); } - + this->Send(ExecuterId, evState.release(), NActors::IEventHandle::FlagTrackDelivery); LastSendStatsTime = now; |