aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoraozeritsky <aozeritsky@ydb.tech>2023-08-24 13:14:35 +0300
committeraozeritsky <aozeritsky@ydb.tech>2023-08-24 13:29:34 +0300
commite5edbf11558c12629e2674b39f9367efc25ddb27 (patch)
treec49c334993a8a570231c44d597cafc80a50b2486
parent88ec08523b5f8060245fc590a437a7eee8ab1244 (diff)
downloadydb-e5edbf11558c12629e2674b39f9367efc25ddb27.tar.gz
Fix use after move
-rw-r--r--ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp15
1 files changed, 8 insertions, 7 deletions
diff --git a/ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp b/ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp
index cf3fcd831b..0e714ab75a 100644
--- a/ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp
+++ b/ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp
@@ -452,6 +452,14 @@ private:
}
ParentId = ev->Sender;
+ {
+ Yql::DqsProto::TTaskMeta taskMeta;
+ ev->Get()->Task.GetMeta().UnpackTo(&taskMeta);
+ Settings->Dispatch(taskMeta.GetSettings());
+ Settings->FreezeDefaults();
+ StageId = taskMeta.GetStageId();
+ }
+
try {
NDq::TDqTaskSettings settings(&ev->Get()->Task);
TaskRunner = Factory->GetOld(settings, TraceId);
@@ -462,13 +470,6 @@ private:
}
auto* actorSystem = TActivationContext::ActorSystem();
- {
- Yql::DqsProto::TTaskMeta taskMeta;
- ev->Get()->Task.GetMeta().UnpackTo(&taskMeta);
- Settings->Dispatch(taskMeta.GetSettings());
- Settings->FreezeDefaults();
- StageId = taskMeta.GetStageId();
- }
Invoker->Invoke([taskRunner=TaskRunner, replyTo, selfId, cookie, actorSystem, settings=Settings, stageId=StageId, startTime, clusterName = ClusterName](){
try {
//auto guard = taskRunner->BindAllocator(); // only for local mode