diff options
| author | Daniil Cherednik <[email protected]> | 2023-03-31 10:54:08 +0300 |
|---|---|---|
| committer | Daniil Cherednik <[email protected]> | 2023-03-31 12:28:07 +0300 |
| commit | fc1cffcfa7f0497a1f97b384a24bcbf23362f3be (patch) | |
| tree | c15f7ab5b9e9b20fd0ef8fc07d598d28e8b32004 /ydb/services/bg_tasks/ds_table/finish_task.cpp | |
| parent | 8a749596d40e91c896a1907afcd108d9221fbde1 (diff) | |
Ydb stable 23-1-1923.1.19
x-stable-origin-commit: c5d5a396e89d0a72e0267a55e93d8404d4fb54fe
Diffstat (limited to 'ydb/services/bg_tasks/ds_table/finish_task.cpp')
| -rw-r--r-- | ydb/services/bg_tasks/ds_table/finish_task.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/ydb/services/bg_tasks/ds_table/finish_task.cpp b/ydb/services/bg_tasks/ds_table/finish_task.cpp index b5dbed8204b..5301971d838 100644 --- a/ydb/services/bg_tasks/ds_table/finish_task.cpp +++ b/ydb/services/bg_tasks/ds_table/finish_task.cpp @@ -5,13 +5,13 @@ namespace NKikimr::NBackgroundTasks { std::optional<NMetadata::NRequest::TDialogYQLRequest::TRequest> TDropTaskActor::OnSessionId(const TString& sessionId) { Ydb::Table::ExecuteDataQueryRequest request; TStringBuilder sb; - sb << "DECLARE $taskId AS String;" << Endl; + sb << "DECLARE $taskId AS Utf8;" << Endl; sb << "DELETE FROM `" + Controller->GetTableName() + "` ON SELECT $taskId AS id"; request.mutable_query()->set_yql_text(sb); auto& idString = (*request.mutable_parameters())["$taskId"]; - idString.mutable_value()->set_bytes_value(TaskId); - idString.mutable_type()->set_type_id(Ydb::Type::STRING); + idString.mutable_value()->set_text_value(TaskId); + idString.mutable_type()->set_type_id(Ydb::Type::UTF8); request.set_session_id(sessionId); request.mutable_tx_control()->mutable_begin_tx()->mutable_serializable_read_write(); |