File Coverage

blib/lib/Proc/JobQueue/Sequence.pm

Criterion	Covered	Total	%
statement	36	36	100.0
branch	2	2	100.0
condition			n/a
subroutine	10	10	100.0
pod	1	2	50.0
total	49	50	98.0

package Proc::JobQueue::Sequence;

# $Id: Sequence.pm 13848 2009-07-23 21:34:00Z david $

use strict;
use warnings;
use Proc::JobQueue::Job;
use Hash::Util qw(lock_keys unlock_keys);
our @ISA = qw(Proc::JobQueue::Job);
use List::MoreUtils qw(all);
use Scalar::Util qw(weaken);
use Proc::JobQueue::DependencyTask;

sub new
{
	my ($pkg, $opts, $config, @jobs) = @_;

	my $job = $pkg->SUPER::new(
		opts		=> $opts,
		config		=> $config,
		jobs		=> \@jobs,
		priority	=> 20,
	);
	return $job;
}

sub startup
{
	my $job = shift;

	my $graph = $job->{queue}->graph();

	my @last = ();
	for my $subtask (@{$job->{jobs}}) {
		$graph->add($subtask, @last);
		@last = ( $subtask );
	}

	my $finish = Proc::JobQueue::DependencyTask->new(
		desc	=> 'mark Sequence as done',
		func	=> sub {
			$graph->remove_dependency($job)
				if $graph->is_dependency($job);
			return 'done';
		},
	);

	$graph->add($finish, @last);

	$job->{queue}->job_part_finished($job, 0);
}

__END__