@@ -403,7 +403,7 @@ async fn main() -> YdbResult<()> {
403403 VALUES ($topic, $partition, $offset, $body)
404404 "
405405 )
406- . with_params ( ydb_params ! (
406+ . with_params ( ydb_params ! (
407407 "$topic" => topic. clone( ) ,
408408 "$partition" => partition_id,
409409 "$offset" => offset,
@@ -412,12 +412,11 @@ async fn main() -> YdbResult<()> {
412412 ) . await ?;
413413
414414 println ! ( " Stored message: topic={}, partition={}, offset={}, body_len={}" ,
415- topic, partition_id, offset, body_str. len( ) ) ;
415+ topic, partition_id, offset, body_str. len( ) ) ;
416416 }
417417
418- // Commit the transaction explicitly for the first example
419- // NOTE: You can omit explicit commit() - the retrier will commit automatically
420- // if the transaction function returns Ok() without errors
418+ // Explicit commit currently required
419+ // Will be auto-committed in future SDK versions
421420 t. commit ( ) . await ?;
422421 println ! ( " Transaction committed successfully" ) ;
423422
@@ -518,8 +517,9 @@ async fn main() -> YdbResult<()> {
518517 } ) ;
519518 }
520519
521- // No explicit commit here - demonstrating automatic commit behavior
522- // The retrier will commit this transaction automatically since we return Ok()
520+ // Explicit commit currently required
521+ // Will be auto-committed in future SDK versions
522+ t. commit ( ) . await ?;
523523
524524 // Return the data for processing outside the transaction
525525 Ok ( rows)
0 commit comments