grahamc/hydra2 - Change LEW5O57PMQ4SMFWYFWJ22R3IFJ63RPV5FMPEAGW3JRZCDJCR5WNAC

t/Setup: move subs calling hydra-* programs to a CliPrograms module

Makes it so HydraTestContext can call them without an import loop

Created by Graham Christensen on December 14, 2021

LEW5O57PMQ4SMFWYFWJ22R3IFJ63RPV5FMPEAGW3JRZCDJCR5WNAC

Dependencies

In channels

main

Change contents

File addition: CliRunners.pm (----------)

[6.2459]

use warnings;
use strict;
package CliRunners;
our @ISA = qw(Exporter);
our @EXPORT = qw(
                 evalSucceeds runBuild sendNotifications
                 captureStdoutStderr);
sub captureStdoutStderr {
    # "Lazy"-load Hydra::Helper::Nix to avoid the compile-time
    # import of Hydra::Model::DB. Early loading of the DB class
    # causes fixation of the DSN, and we need to fixate it after
    # the temporary DB is setup.
    require Hydra::Helper::Nix;
    return Hydra::Helper::Nix::captureStdoutStderr(@_)
}
sub evalSucceeds {
    my ($jobset) = @_;
    my ($res, $stdout, $stderr) = captureStdoutStderr(60, ("hydra-eval-jobset", $jobset->project->name, $jobset->name));
    $jobset->discard_changes;  # refresh from DB
    chomp $stdout; chomp $stderr;
    print STDERR "Evaluation errors for jobset ".$jobset->project->name.":".$jobset->name.": \n".$jobset->errormsg."\n" if $jobset->errormsg;
    print STDERR "STDOUT: $stdout\n" if $stdout ne "";
    print STDERR "STDERR: $stderr\n" if $stderr ne "";
    return !$res;
}
sub runBuild {
    my ($build) = @_;
    my ($res, $stdout, $stderr) = captureStdoutStderr(60, ("hydra-queue-runner", "-vvvv", "--build-one", $build->id));
    if ($res) {
        print STDERR "Queue runner stdout: $stdout\n" if $stdout ne "";
        print STDERR "Queue runner stderr: $stderr\n" if $stderr ne "";
    }
    return !$res;
}
sub sendNotifications() {
    my ($res, $stdout, $stderr) = captureStdoutStderr(60, ("hydra-notify", "--queued-only"));
    if ($res) {
        print STDERR "hydra notify stdout: $stdout\n" if $stdout ne "";
        print STDERR "hydra notify stderr: $stderr\n" if $stderr ne "";
    }
    return !$res;
}
1;

Insertion in t/lib/Setup.pm at line 11 [7.518]
[3.1330]
[7.561]
```
use CliRunners;
```

Deletion in t/lib/Setup.pm at line 47 [7.518]

∅:D[8.137] → [9.915:1256]

∅:D[4.1031] → [9.915:1256]

∅:D[10.2224] → [9.915:1256]

B:BD[9.915] → [9.915:1256]

}
sub captureStdoutStderr {
    # "Lazy"-load Hydra::Helper::Nix to avoid the compile-time
    # import of Hydra::Model::DB. Early loading of the DB class
    # causes fixation of the DSN, and we need to fixate it after
    # the temporary DB is setup.
    require Hydra::Helper::Nix;
    return Hydra::Helper::Nix::captureStdoutStderr(@_)

Deletion in t/lib/Setup.pm at line 96 [7.518]

∅:D[11.1172] → [7.763:766]

∅:D[12.1312] → [7.763:766]

B:BD[7.763] → [7.763:766]

B:BD[7.766] → [11.1173:1192]

B:BD[11.1192] → [12.1313:1336]

B:BD[12.1336] → [13.11450:11571]

B:BD[13.11571] → [5.0:49]

∅:D[5.49] → [12.1469:1755]

∅:D[14.9463] → [12.1469:1755]

∅:D[13.11571] → [12.1469:1755]

B:BD[12.1469] → [12.1469:1755]

B:BD[12.1755] → [15.3646:3664]

∅:D[12.1772] → [11.1482:1485]

∅:D[15.3664] → [11.1482:1485]

B:BD[11.1482] → [11.1482:1485]

B:BD[11.1485] → [16.707:722]

B:BD[16.722] → [12.1773:1795]

B:BD[12.1795] → [17.1696:1815]

B:BD[17.1815] → [2.62:228]

∅:D[2.228] → [15.3711:3729]

∅:D[17.1815] → [15.3711:3729]

B:BD[15.3711] → [15.3711:3729]

∅:D[18.271] → [19.4328:4331]

∅:D[12.1971] → [19.4328:4331]

∅:D[15.3729] → [19.4328:4331]

B:BD[20.440] → [19.4328:4331]

B:BD[19.4331] → [21.900:1204]

}
sub evalSucceeds {
    my ($jobset) = @_;
    my ($res, $stdout, $stderr) = captureStdoutStderr(60, ("hydra-eval-jobset", $jobset->project->name, $jobset->name));
    $jobset->discard_changes;  # refresh from DB
    chomp $stdout; chomp $stderr;
    print STDERR "Evaluation errors for jobset ".$jobset->project->name.":".$jobset->name.": \n".$jobset->errormsg."\n" if $jobset->errormsg;
    print STDERR "STDOUT: $stdout\n" if $stdout ne "";
    print STDERR "STDERR: $stderr\n" if $stderr ne "";
    return !$res;
}
sub runBuild {
    my ($build) = @_;
    my ($res, $stdout, $stderr) = captureStdoutStderr(60, ("hydra-queue-runner", "-vvvv", "--build-one", $build->id));
    if ($res) {
        print STDERR "Queue runner stdout: $stdout\n" if $stdout ne "";
        print STDERR "Queue runner stderr: $stderr\n" if $stderr ne "";
    }
    return !$res;
}
sub sendNotifications() {
    my ($res, $stdout, $stderr) = captureStdoutStderr(60, ("hydra-notify", "--queued-only"));
    if ($res) {
        print STDERR "hydra notify stdout: $stdout\n" if $stdout ne "";
        print STDERR "hydra notify stderr: $stderr\n" if $stderr ne "";
    }
    return !$res;