diff --git a/lib/NGCP/BulkProcessor/SqlProcessor.pm b/lib/NGCP/BulkProcessor/SqlProcessor.pm index 85535910..3a3b869d 100644 --- a/lib/NGCP/BulkProcessor/SqlProcessor.pm +++ b/lib/NGCP/BulkProcessor/SqlProcessor.pm @@ -793,7 +793,7 @@ sub transfer_table { tabletransferstarted($db,$tablename,$target_db,$targettablename,$rowcount,getlogger(__PACKAGE__)); } else { transferzerorowcount($db,$tablename,$target_db,$targettablename,$rowcount,getlogger(__PACKAGE__)); - return; + return 1; } my $errorstate = $RUNNING; # 1; @@ -1079,7 +1079,7 @@ sub process_table { tableprocessingstarted($db,$tablename,$rowcount,getlogger(__PACKAGE__)); } else { processzerorowcount($db,$tablename,$rowcount,getlogger(__PACKAGE__)); - return; + return 1; } my @fieldnames = @$expected_fieldnames;