File Coverage

blib/lib/HPC/Runner/Command/execute_job.pm

Criterion	Covered	Total	%
statement	12	18	66.6
branch	2	6	33.3
condition			n/a
subroutine	3	4	75.0
pod			n/a
total	17	28	60.7

package HPC::Runner::Command::execute_job;

use MooseX::App::Command;
use JSON;

extends 'HPC::Runner::Command';

with 'HPC::Runner::Command::Logger::JSON';
with 'HPC::Runner::Command::Utils::Base';
with 'HPC::Runner::Command::Utils::Log';
with 'HPC::Runner::Command::Utils::Git';
with 'HPC::Runner::Command::execute_job::Utils::MCE';

command_short_description 'Execute commands';
command_long_description
  'Take the parsed files from hpcrunner.pl submit_jobs and executes the code';

option 'batch_index_start' => (
    is        => 'rw',
    isa       => 'Num',
    required  => 0,
    predicate => 'has_batch_index_start',
    documentation =>
      'Counter to tell execute_array where to start reading in the infile.'
      . ' Omit this option in order to run in single node.'
);

sub BUILD {
    my $self = shift;

    $self->gen_load_plugins;
    $self->job_load_plugins;

    my $job_meta;
    if ( $self->metastr ) {
        $job_meta = decode_json( $self->metastr );
    }
    return unless defined $job_meta;

    if(exists $job_meta->{job_cmd_start}){
      $self->counter($job_meta->{job_cmd_start} + $self->batch_index_start);
    }
}

sub execute {
    my $self = shift;

    $self->git_things;
    $self->run_mce;
}

1;