sub manager {
    my ($Operation) = @_;

    my @row = $Operation->getnew;
    $Operation->log->debug( 'getnew rows:' . scalar(@row) );

    $Operation->recordi(0);
    for my $row (@row) {
        $Operation->recordi( $Operation->recordi + 1 );

        $Operation->log->debug( ' --- data --- ' . Dumper($row) );
        $Operation->data($row);
        $Operation->process;

	$Operation->updateprogress;
    }

}