Use retryable code for error when DQ leader is changed (#17288)

rvu1024 · web-flow · commit 979cba78b76f · 2025-04-16T17:57:57.000+03:00
diff --git a/ydb/library/yql/providers/dq/global_worker_manager/global_worker_manager.cpp b/ydb/library/yql/providers/dq/global_worker_manager/global_worker_manager.cpp
@@ -671,7 +671,7 @@ class TGlobalWorkerManager: public TWorkerManagerCommon<TGlobalWorkerManager> {
             Send(value.ActorId, new TEvents::TEvPoison());
         }
         for (const auto sender : Scheduler->Cleanup()) {
-            Send(sender, new TEvAllocateWorkersResponse("StartFollower", NYql::NDqProto::StatusIds::UNSPECIFIED));
+            Send(sender, new TEvAllocateWorkersResponse("Worker reallocation is required because of DQ leader change", NYql::NDqProto::StatusIds::UNAVAILABLE));
         }
         AllocatedResources.clear();
         for (auto& [k, v] : LiteralQueries) {

Original file line number	Diff line number	Diff line change
`@@ -671,7 +671,7 @@ class TGlobalWorkerManager: public TWorkerManagerCommon<TGlobalWorkerManager> {`
`671`	`671`	`Send(value.ActorId, new TEvents::TEvPoison());`
`672`	`672`	`}`
`673`	`673`	`for (const auto sender : Scheduler->Cleanup()) {`
`674`		`- Send(sender, new TEvAllocateWorkersResponse("StartFollower", NYql::NDqProto::StatusIds::UNSPECIFIED));`
	`674`	`+ Send(sender, new TEvAllocateWorkersResponse("Worker reallocation is required because of DQ leader change", NYql::NDqProto::StatusIds::UNAVAILABLE));`
`675`	`675`	`}`
`676`	`676`	`AllocatedResources.clear();`
`677`	`677`	`for (auto& [k, v] : LiteralQueries) {`