Add pool specifying in yt sink

commit_hash:45b9434bc2d5398cbd3b887e7e99db1be7e124db
doublecloud · Jan 16, 2025 · 228daa1 · 228daa1
1 parent 19012cd
commit 228daa1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/providers/yt/sink/single_static_table.go b/pkg/providers/yt/sink/single_static_table.go
@@ -281,7 +281,7 @@ func (t *SingleStaticTable) commit(ctx context.Context) error {
 		t.logger.Info("commit static table [step 3] -- sort table", log.String("src_table", t.tmpTableName),
 			log.String("dst_table", t.tmpTableName))
 		sortOperationID, err := t.tx.StartOperation(ctx, yt.OperationSort, map[string]interface{}{
-			"pool":                  "transfer_manager",
+			"pool":                  t.config.Pool(),
 			"input_table_paths":     []ypath.Path{tmpTableYPath},
 			"output_table_path":     mergedTableYPath,
 			"sort_by":               t.schemaKeys(),