@@ -, +, @@ --- tools/manage-marc-import.pl | 30 +++++++++++++----------------- 1 file changed, 13 insertions(+), 17 deletions(-) --- a/tools/manage-marc-import.pl +++ a/tools/manage-marc-import.pl @@ -233,21 +233,17 @@ sub commit_batch { my ( $num_added, $num_updated, $num_items_added, $num_items_replaced, $num_items_errored, $num_ignored ); my $schema = Koha::Database->new->schema; - $schema->storage->txn_do( - sub { - my $callback = sub { }; - if ($runinbackground) { - $job = put_in_background($import_batch_id); - $callback = progress_callback( $job, $dbh ); - } - ( - $num_added, $num_updated, $num_items_added, - $num_items_replaced, $num_items_errored, $num_ignored - ) - = BatchCommitRecords( $import_batch_id, $framework, 50, - $callback ); - } - ); + my $callback = sub { }; + if ($runinbackground) { + $job = put_in_background($import_batch_id); + $callback = progress_callback( $job ); + } + ( + $num_added, $num_updated, $num_items_added, + $num_items_replaced, $num_items_errored, $num_ignored + ) + = BatchCommitRecords( $import_batch_id, $framework, 50, + $callback ); my $results = { did_commit => 1, @@ -340,11 +336,11 @@ sub put_in_background { sub progress_callback { my $job = shift; - my $dbh = shift; return sub { my $progress = shift; + my $schema = shift; $job->progress($progress); - $dbh->commit(); + $schema->txn_commit; } } --