File Coverage

blib/lib/TheSchwartz/Worker.pm

Criterion	Covered	Total	%
statement	9	35	25.7
branch	0	4	0.0
condition	0	3	0.0
subroutine	3	9	33.3
pod	6	6	100.0
total	18	57	31.5

# $Id$

package TheSchwartz::Worker;
use strict;

use Carp qw( croak );
use Storable ();

sub grab_job {
    my $class = shift;
    my ($client) = @_;
    return $client->find_job_for_workers( [$class] );
}

sub keep_exit_status_for {0}
sub max_retries          {0}
sub retry_delay          {0}
sub grab_for             { 60 * 60 }    ## 1 hour

sub work_safely {
    my ( $class, $job ) = @_;
    my $client = $job->handle->client;
    my $res;

    $job->debug("Working on $class ...");
    $job->set_as_current;
    $client->start_scoreboard;

    eval { $res = $class->work($job); };
    my $errstr = $@;

    my $cjob = $client->current_job;
    if ($errstr) {

        # something went wrong, better make a rollback!
        my $driver = $cjob->driver;
        $driver->rollback;

        $job->debug("Eval failure: $errstr");
        $cjob->failed($errstr);
    }
    if ( !$cjob->was_declined && !$cjob->did_something ) {
        $cjob->failed(
            'Job did not explicitly complete, fail, or get replaced');
    }

    $client->end_scoreboard;

# FIXME: this return value is kinda useless/undefined.  should we even return anything?  any callers? -brad
    return $res;
}

1;

__END__