diff options
author | aozeritsky <aozeritsky@ydb.tech> | 2023-08-24 13:14:35 +0300 |
---|---|---|
committer | aozeritsky <aozeritsky@ydb.tech> | 2023-08-24 13:29:34 +0300 |
commit | e5edbf11558c12629e2674b39f9367efc25ddb27 (patch) | |
tree | c49c334993a8a570231c44d597cafc80a50b2486 | |
parent | 88ec08523b5f8060245fc590a437a7eee8ab1244 (diff) | |
download | ydb-e5edbf11558c12629e2674b39f9367efc25ddb27.tar.gz |
Fix use after move
-rw-r--r-- | ydb/library/yql/providers/dq/task_runner_actor/task_runner_actor.cpp | 15 |
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 |