janik/hydra
0
0
Fork 0
forked from lix-project/hydra
Code Pull requests Activity

Sort notification classes / events

Browse source
This commit is contained in:
Graham Christensen 2022-02-07 15:55:29 -05:00
parent 7b7c03a521
commit 8a18326f2b
2 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/lib/Hydra/Event.pm
View file

@ -2,20 +2,20 @@ package Hydra::Event;
use strict; use strict;
use warnings; use warnings;
use Hydra::Event::CachedBuildFinished;
use Hydra::Event::CachedBuildQueued;
use Hydra::Event::BuildFinished; use Hydra::Event::BuildFinished;
use Hydra::Event::BuildQueued; use Hydra::Event::BuildQueued;
use Hydra::Event::BuildStarted; use Hydra::Event::BuildStarted;
use Hydra::Event::CachedBuildFinished;
use Hydra::Event::CachedBuildQueued;
use Hydra::Event::StepFinished; use Hydra::Event::StepFinished;
my %channels_to_events = ( my %channels_to_events = (
build_finished => \&Hydra::Event::BuildFinished::parse,
build_queued => \&Hydra::Event::BuildQueued::parse, build_queued => \&Hydra::Event::BuildQueued::parse,
build_started => \&Hydra::Event::BuildStarted::parse, build_started => \&Hydra::Event::BuildStarted::parse,
step_finished => \&Hydra::Event::StepFinished::parse,
build_finished => \&Hydra::Event::BuildFinished::parse,
cached_build_finished => \&Hydra::Event::CachedBuildFinished::parse, cached_build_finished => \&Hydra::Event::CachedBuildFinished::parse,
cached_build_queued => \&Hydra::Event::CachedBuildQueued::parse, cached_build_queued => \&Hydra::Event::CachedBuildQueued::parse,
step_finished => \&Hydra::Event::StepFinished::parse,
); );

8
t/scripts/hydra-eval-jobset/notifications.t
View file

@ -17,14 +17,14 @@ path_input_cache_validity_seconds = 0
my $dbh = $ctx->db()->storage->dbh; my $dbh = $ctx->db()->storage->dbh;
my $listener = Hydra::PostgresListener->new($dbh); my $listener = Hydra::PostgresListener->new($dbh);
$listener->subscribe("build_queued");
$listener->subscribe("builds_added");
$listener->subscribe("cached_build_finished"); $listener->subscribe("cached_build_finished");
$listener->subscribe("cached_build_queued"); $listener->subscribe("cached_build_queued");
$listener->subscribe("build_queued");
$listener->subscribe("eval_failed");
$listener->subscribe("eval_cached");
$listener->subscribe("eval_added"); $listener->subscribe("eval_added");
$listener->subscribe("eval_cached");
$listener->subscribe("eval_failed");
$listener->subscribe("eval_started"); $listener->subscribe("eval_started");
$listener->subscribe("builds_added");
my $jobsetdir = $ctx->tmpdir . '/jobset'; my $jobsetdir = $ctx->tmpdir . '/jobset';