From c4134c8e840444387d11290e4ad3d4062bf9fdba Mon Sep 17 00:00:00 2001 From: Graham Christensen Date: Thu, 26 Aug 2021 16:32:41 -0400 Subject: [PATCH] TaskRetries: init table --- src/lib/Hydra/Schema/Result/TaskRetries.pm | 110 +++++++++++++++++++++ src/sql/hydra.sql | 15 +++ src/sql/update-dbix.pl | 1 + src/sql/upgrade-77.sql | 15 +++ 4 files changed, 141 insertions(+) create mode 100644 src/lib/Hydra/Schema/Result/TaskRetries.pm create mode 100644 src/sql/upgrade-77.sql diff --git a/src/lib/Hydra/Schema/Result/TaskRetries.pm b/src/lib/Hydra/Schema/Result/TaskRetries.pm new file mode 100644 index 00000000..08c7e8f6 --- /dev/null +++ b/src/lib/Hydra/Schema/Result/TaskRetries.pm @@ -0,0 +1,110 @@ +use utf8; +package Hydra::Schema::Result::TaskRetries; + +# Created by DBIx::Class::Schema::Loader +# DO NOT MODIFY THE FIRST PART OF THIS FILE + +=head1 NAME + +Hydra::Schema::Result::TaskRetries + +=cut + +use strict; +use warnings; + +use base 'DBIx::Class::Core'; + +=head1 COMPONENTS LOADED + +=over 4 + +=item * L + +=back + +=cut + +__PACKAGE__->load_components("+Hydra::Component::ToJSON"); + +=head1 TABLE: C + +=cut + +__PACKAGE__->table("taskretries"); + +=head1 ACCESSORS + +=head2 id + + data_type: 'integer' + is_auto_increment: 1 + is_nullable: 0 + sequence: 'taskretries_id_seq' + +=head2 channel + + data_type: 'text' + is_nullable: 0 + +=head2 pluginname + + data_type: 'text' + is_nullable: 0 + +=head2 payload + + data_type: 'text' + is_nullable: 0 + +=head2 attempts + + data_type: 'integer' + is_nullable: 0 + +=head2 retry_at + + data_type: 'integer' + is_nullable: 0 + +=cut + +__PACKAGE__->add_columns( + "id", + { + data_type => "integer", + is_auto_increment => 1, + is_nullable => 0, + sequence => "taskretries_id_seq", + }, + "channel", + { data_type => "text", is_nullable => 0 }, + "pluginname", + { data_type => "text", is_nullable => 0 }, + "payload", + { data_type => "text", is_nullable => 0 }, + "attempts", + { data_type => "integer", is_nullable => 0 }, + "retry_at", + { data_type => "integer", is_nullable => 0 }, +); + +=head1 PRIMARY KEY + +=over 4 + +=item * L + +=back + +=cut + +__PACKAGE__->set_primary_key("id"); + + +# Created by DBIx::Class::Schema::Loader v0.07049 @ 2021-08-26 16:30:59 +# DO NOT MODIFY THIS OR ANYTHING ABOVE! md5sum:4MC8UnsgrvJVRrIURvSH5A + + +# You can replace this text with custom code or comments, and it will be preserved on regeneration +1; diff --git a/src/sql/hydra.sql b/src/sql/hydra.sql index 9f5857c2..0acbc537 100644 --- a/src/sql/hydra.sql +++ b/src/sql/hydra.sql @@ -553,6 +553,21 @@ create table StarredJobs ( foreign key (project, jobset) references Jobsets(project, name) on update cascade on delete cascade ); +-- Events processed by hydra-notify which have failed at least once +-- +-- The payload field contains the original, unparsed payload. +-- +-- One row is created for each plugin which fails to process the event, +-- with an increasing retry_at and attempts field. +create table TaskRetries ( + id serial primary key not null, + channel text not null, + pluginname text not null, + payload text not null, + attempts integer not null, + retry_at integer not null +); +create index IndexTaskRetriesOrdered on TaskRetries(retry_at asc); -- The output paths that have permanently failed. create table FailedPaths ( diff --git a/src/sql/update-dbix.pl b/src/sql/update-dbix.pl index a9a18f0e..97061f21 100644 --- a/src/sql/update-dbix.pl +++ b/src/sql/update-dbix.pl @@ -39,6 +39,7 @@ make_schema_at("Hydra::Schema", { "starredjobs" => "StarredJobs", "systemstatus" => "SystemStatus", "systemtypes" => "SystemTypes", + "taskretries" => "TaskRetries", "urirevmapper" => "UriRevMapper", "userroles" => "UserRoles", "users" => "Users", diff --git a/src/sql/upgrade-77.sql b/src/sql/upgrade-77.sql new file mode 100644 index 00000000..bc67cc9d --- /dev/null +++ b/src/sql/upgrade-77.sql @@ -0,0 +1,15 @@ +-- Events processed by hydra-notify which have failed at least once +-- +-- The payload field contains the original, unparsed payload. +-- +-- One row is created for each plugin which fails to process the event, +-- with an increasing retry_at and attempts field. +create table TaskRetries ( + id serial primary key not null, + channel text not null, + pluginname text not null, + payload text not null, + attempts integer not null, + retry_at integer not null +); +create index IndexTaskRetriesOrdered on TaskRetries(retry_at asc);