Skip to content

Commit 146a0a8

Browse files
authored
async CA: remove unused code (#11628)
1 parent 30604fd commit 146a0a8

File tree

1 file changed

+0
-19
lines changed

1 file changed

+0
-19
lines changed

ydb/library/yql/dq/actors/compute/dq_async_compute_actor.cpp

Lines changed: 0 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -16,15 +16,6 @@ constexpr TDuration MIN_QUOTED_CPU_TIME = TDuration::MilliSeconds(10);
1616

1717
using namespace NActors;
1818

19-
namespace {
20-
21-
bool IsDebugLogEnabled(const TActorSystem* actorSystem) {
22-
auto* settings = actorSystem->LoggerSettings();
23-
return settings && settings->Satisfies(NActors::NLog::EPriority::PRI_DEBUG, NKikimrServices::KQP_COMPUTE);
24-
}
25-
26-
} // anonymous namespace
27-
2819
//Used in Async CA to interact with TaskRunnerActor
2920
struct TComputeActorAsyncInputHelperAsync : public TComputeActorAsyncInputHelper
3021
{
@@ -96,16 +87,6 @@ class TDqAsyncComputeActor : public TDqComputeActorBase<TDqAsyncComputeActor, TC
9687
}
9788

9889
void DoBootstrap() {
99-
const TActorSystem* actorSystem = TlsActivationContext->ActorSystem();
100-
101-
TLogFunc logger;
102-
if (IsDebugLogEnabled(actorSystem)) {
103-
logger = [actorSystem, txId = GetTxId(), taskId = Task.GetId()] (const TString& message) {
104-
LOG_DEBUG_S(*actorSystem, NKikimrServices::KQP_COMPUTE, "TxId: " << txId
105-
<< ", task: " << taskId << ": " << message);
106-
};
107-
}
108-
10990
NActors::IActor* actor;
11091
THashSet<ui32> inputWithDisabledCheckpointing;
11192
for (const auto&[idx, inputInfo]: InputChannelsMap) {

0 commit comments

Comments
 (0)