{"header":{"message":"TaskDispatcher: Support re-queueing tasks, and dropping tasks after 100 failures.","description":null,"timestamp":"2021-08-26T21:00:39Z","authors":[{"email":"graham@grahamc.com","name":"Graham Christensen"}]},"hash":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC","authors":[],"deps":{"hashes":[["I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC","TaskDispatcher: Support re-queueing tasks, and dropping tasks after 100 failures."],["AA",null],["SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC","hydra-notify: extract runPluginsForEvent to a TaskDispatcher"]],"deps":["SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC"],"known":[]},"hunks":[{"Edit":{"inode":{"change":2,"pos":244},"path":"src/lib/Hydra/TaskDispatcher.pm","line":20,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":817}],"down_context":[{"change":2,"pos":817}],"flag":"BLOCK","start":0,"end":641,"inode":{"change":2,"pos":244}}},"contents":[{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:0"}},{"Add":{"text":"The dispatcher's behavior is slightly different based on","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:57"}},{"Add":{"text":"if the Task has an associated record:","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:95"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:96"}},{"Add":{"text":"=over 1","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:104"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:105"}},{"Add":{"text":"=item *","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:113"}},{"Add":{"text":"If a task succeeds and there is no record, the Dispatcher","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:171"}},{"Add":{"text":"assumes there is no further accounting of the task to be","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:228"}},{"Add":{"text":"done.","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:234"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:235"}},{"Add":{"text":"=item *","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:243"}},{"Add":{"text":"If a task succeeds and there is a record, the Dispatcher","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:300"}},{"Add":{"text":"calls C on the record.","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:331"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:332"}},{"Add":{"text":"=item *","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:340"}},{"Add":{"text":"If a task fails and there is no record, the Dispatcher","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:395"}},{"Add":{"text":"calls C<$store_task> with the Task as its only argument.","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:452"}},{"Add":{"text":"It is the C<$store_task>'s responsibility to store the","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:507"}},{"Add":{"text":"task in some way for retrying.","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:538"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:539"}},{"Add":{"text":"=item *","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:547"}},{"Add":{"text":"If a task fails and there is a record, the Dispatcher","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:601"}},{"Add":{"text":"calls C on the record.","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:633"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:634"}},{"Add":{"text":"=back","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:640"}}]}},{"Edit":{"inode":{"change":2,"pos":244},"path":"src/lib/Hydra/TaskDispatcher.pm","line":58,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":908},"to":{"change":2,"start":908,"end":915},"introduced_by":2}],"inode":{"change":2,"pos":244}}},"contents":[{"Del":{"text":"=back","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:913"}},{"Del":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:914"}}]}},{"Edit":{"inode":{"change":2,"pos":244},"path":"src/lib/Hydra/TaskDispatcher.pm","line":61,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":1075},"to":{"change":2,"start":1075,"end":1082},"introduced_by":2}],"inode":{"change":2,"pos":244}}},"contents":[{"Del":{"text":"","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1075"}},{"Del":{"text":"=back","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1081"}}]}},{"Edit":{"inode":{"change":2,"pos":244},"path":"src/lib/Hydra/TaskDispatcher.pm","line":64,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":1179}],"down_context":[{"change":2,"pos":1179}],"flag":"BLOCK","start":642,"end":921,"inode":{"change":2,"pos":244}}},"contents":[{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:642"}},{"Add":{"text":"=item C<$store_task> (Optional)","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:674"}},{"Add":{"text":"A sub to call when storing a task for the first time. This sub is called","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:747"}},{"Add":{"text":"after a L's execution fails without an associated record.","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:818"}},{"Add":{"text":"The sub is called with the failing task, and is responsible for storing","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:890"}},{"Add":{"text":"the task for another attempt.","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:920"}}]}},{"Edit":{"inode":{"change":2,"pos":244},"path":"src/lib/Hydra/TaskDispatcher.pm","line":71,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":1180}],"down_context":[{"change":2,"pos":1180}],"flag":"BLOCK","start":922,"end":992,"inode":{"change":2,"pos":244}}},"contents":[{"Add":{"text":"If no C<$store_task> sub is provided, all failed events are dropped.","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:990"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:991"}}]}},{"Replacement":{"inode":{"change":2,"pos":244},"path":"src/lib/Hydra/TaskDispatcher.pm","line":78,"ins":{"up_context":[{"change":2,"pos":1203}],"down_context":[{"change":2,"pos":1252}],"flag":"BLOCK","start":993,"end":1055,"inode":{"change":2,"pos":244}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":1203},"to":{"change":2,"start":1203,"end":1252},"introduced_by":2}],"inode":{"change":2,"pos":244}},"ins_contents":[{"Add":{"text":" my ($self, $db, $prometheus, $plugins, $store_task) = @_;","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1054"}}],"del_contents":[{"Del":{"text":" my ($self, $db, $prometheus, $plugins) = @_;","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:1251"}}]}},{"Edit":{"inode":{"change":2,"pos":244},"path":"src/lib/Hydra/TaskDispatcher.pm","line":100,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":1938}],"down_context":[{"change":2,"pos":1938}],"flag":"BLOCK","start":1056,"end":1562,"inode":{"change":2,"pos":244}}},"contents":[{"Add":{"text":" $prometheus->declare(","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1081"}},{"Add":{"text":" \"notify_plugin_retry_success\",","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1120"}},{"Add":{"text":" type => \"counter\",","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1147"}},{"Add":{"text":" help => \"Number of successful executions of retried tasks.\"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1215"}},{"Add":{"text":" );","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1222"}},{"Add":{"text":" $prometheus->declare(","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1248"}},{"Add":{"text":" \"notify_plugin_drop\",","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1278"}},{"Add":{"text":" type => \"counter\",","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1305"}},{"Add":{"text":" help => \"Number of tasks that have been dropped after too many retries.\"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1386"}},{"Add":{"text":" );","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1393"}},{"Add":{"text":" $prometheus->declare(","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1419"}},{"Add":{"text":" \"notify_plugin_requeue\",","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1452"}},{"Add":{"text":" type => \"counter\",","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1479"}},{"Add":{"text":" help => \"Number of tasks that have been requeued after a failure.\"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1554"}},{"Add":{"text":" );","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1561"}}]}},{"Edit":{"inode":{"change":2,"pos":244},"path":"src/lib/Hydra/TaskDispatcher.pm","line":118,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":2000}],"down_context":[{"change":2,"pos":2000}],"flag":"BLOCK","start":1563,"end":1633,"inode":{"change":2,"pos":244}}},"contents":[{"Add":{"text":" if (!defined($store_task)) {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1595"}},{"Add":{"text":" $store_task = sub {};","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1625"}},{"Add":{"text":" }","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1631"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1632"}}]}},{"Edit":{"inode":{"change":2,"pos":244},"path":"src/lib/Hydra/TaskDispatcher.pm","line":126,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":2128}],"down_context":[{"change":2,"pos":2128}],"flag":"BLOCK","start":1634,"end":1671,"inode":{"change":2,"pos":244}}},"contents":[{"Add":{"text":" \"store_task\" => $store_task,","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1670"}}]}},{"Replacement":{"inode":{"change":2,"pos":244},"path":"src/lib/Hydra/TaskDispatcher.pm","line":178,"ins":{"up_context":[{"change":2,"pos":3112}],"down_context":[{"change":2,"pos":3210}],"flag":"BLOCK","start":1672,"end":1731,"inode":{"change":2,"pos":244}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":3112},"to":{"change":2,"start":3112,"end":3210},"introduced_by":2}],"inode":{"change":2,"pos":244}},"ins_contents":[{"Add":{"text":" my $event_labels = $self->prom_labels_for_task($task);","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1730"}}],"del_contents":[{"Del":{"text":" my $event_labels = {","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3136"}},{"Del":{"text":" channel => $channel_name,","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3170"}},{"Del":{"text":" plugin => $plugin_name,","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3202"}},{"Del":{"text":" };","pos":"SWXGVPJNE35OLCZD7HOZOJLZZPTWPOKQ6W56Y5EM2TZMNBZJESEQC:3209"}}]}},{"Edit":{"inode":{"change":2,"pos":244},"path":"src/lib/Hydra/TaskDispatcher.pm","line":196,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":3847}],"down_context":[{"change":2,"pos":3847}],"flag":"BLOCK","start":1732,"end":1763,"inode":{"change":2,"pos":244}}},"contents":[{"Add":{"text":" $self->success($task);","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1762"}}]}},{"Edit":{"inode":{"change":2,"pos":244},"path":"src/lib/Hydra/TaskDispatcher.pm","line":199,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":3872}],"down_context":[{"change":2,"pos":3872}],"flag":"BLOCK","start":1764,"end":1795,"inode":{"change":2,"pos":244}}},"contents":[{"Add":{"text":" $self->failure($task);","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1794"}}]}},{"Edit":{"inode":{"change":2,"pos":244},"path":"src/lib/Hydra/TaskDispatcher.pm","line":203,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":4028}],"down_context":[{"change":2,"pos":4028}],"flag":"BLOCK","start":1796,"end":2279,"inode":{"change":2,"pos":244}}},"contents":[{"Add":{"text":" }","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1801"}},{"Add":{"text":"}","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1803"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1804"}},{"Add":{"text":"=head2 success","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1819"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1820"}},{"Add":{"text":"Mark a task's execution as successful.","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1859"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1860"}},{"Add":{"text":"If the task has an associated record, the record is deleted.","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1921"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1922"}},{"Add":{"text":"Arguments:","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1933"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1934"}},{"Add":{"text":"=over 1","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1942"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1943"}},{"Add":{"text":"=item C<$task>","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1958"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:1959"}},{"Add":{"text":"L the task to mark as successful.","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2006"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2007"}},{"Add":{"text":"=back","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2013"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2014"}},{"Add":{"text":"=cut","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2019"}},{"Add":{"text":"sub success {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2033"}},{"Add":{"text":" my ($self, $task) = @_;","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2061"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2062"}},{"Add":{"text":" my $event_labels = $self->prom_labels_for_task($task);","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2121"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2122"}},{"Add":{"text":" if (defined($task->{\"record\"})) {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2160"}},{"Add":{"text":" $self->{\"prometheus\"}->inc(\"notify_plugin_retry_sucess\", $event_labels);","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2241"}},{"Add":{"text":" $task->{\"record\"}->delete();","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2278"}}]}},{"Edit":{"inode":{"change":2,"pos":244},"path":"src/lib/Hydra/TaskDispatcher.pm","line":233,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":4036}],"down_context":[{"change":2,"pos":4036}],"flag":"BLOCK","start":2280,"end":2546,"inode":{"change":2,"pos":244}}},"contents":[{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2280"}},{"Add":{"text":"=head2 failure","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2295"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2296"}},{"Add":{"text":"Mark a task's execution as failed.","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2331"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2332"}},{"Add":{"text":"The task is requeued if it has been attempted fewer than than 100 times.","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2405"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2406"}},{"Add":{"text":"Arguments:","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2417"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2418"}},{"Add":{"text":"=over 1","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2426"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2427"}},{"Add":{"text":"=item C<$task>","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2442"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2443"}},{"Add":{"text":"L the task to mark as successful.","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2490"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2491"}},{"Add":{"text":"=back","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2497"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2498"}},{"Add":{"text":"=cut","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2503"}},{"Add":{"text":"sub failure {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2517"}},{"Add":{"text":" my ($self, $task) = @_;","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2545"}}]}},{"Edit":{"inode":{"change":2,"pos":244},"path":"src/lib/Hydra/TaskDispatcher.pm","line":254,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":4037}],"down_context":[{"change":2,"pos":4037}],"flag":"BLOCK","start":2547,"end":3560,"inode":{"change":2,"pos":244}}},"contents":[{"Add":{"text":" my $event_labels = $self->prom_labels_for_task($task);","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2605"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2606"}},{"Add":{"text":" if (defined($task->{\"record\"})) {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2644"}},{"Add":{"text":" if ($task->{\"record\"}->{\"attempts\"} > 100) {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2697"}},{"Add":{"text":" $self->{\"prometheus\"}->inc(\"notify_plugin_drop\", $event_labels);","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2774"}},{"Add":{"text":" $task->{\"record\"}->delete();","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2815"}},{"Add":{"text":" } else {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2832"}},{"Add":{"text":" $self->{\"prometheus\"}->inc(\"notify_plugin_requeue\", $event_labels);","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2912"}},{"Add":{"text":" $task->{\"record\"}->requeue();","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2954"}},{"Add":{"text":" }","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2964"}},{"Add":{"text":" } else {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:2977"}},{"Add":{"text":" $self->{\"prometheus\"}->inc(\"notify_plugin_requeue\", $event_labels);","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3053"}},{"Add":{"text":" $self->{\"store_task\"}($task);","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3091"}},{"Add":{"text":" }","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3097"}},{"Add":{"text":"}","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3099"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3100"}},{"Add":{"text":"=head2 prom_labels_for_task","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3128"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3129"}},{"Add":{"text":"Given a specific task, return a hash of standard labels to record with","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3200"}},{"Add":{"text":"Prometheus.","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3212"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3213"}},{"Add":{"text":"Arguments:","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3224"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3225"}},{"Add":{"text":"=over 1","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3233"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3234"}},{"Add":{"text":"=item C<$task>","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3249"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3250"}},{"Add":{"text":"L the task to return labels for.","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3296"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3297"}},{"Add":{"text":"=back","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3303"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3304"}},{"Add":{"text":"=cut","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3309"}},{"Add":{"text":"sub prom_labels_for_task {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3336"}},{"Add":{"text":" my ($self, $task) = @_;","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3364"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3365"}},{"Add":{"text":" my $channel_name = $task->{\"event\"}->{'channel_name'};","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3424"}},{"Add":{"text":" my $plugin_name = $task->{\"plugin_name\"};","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3470"}},{"Add":{"text":" return {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3483"}},{"Add":{"text":" channel => $channel_name,","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3517"}},{"Add":{"text":" plugin => $plugin_name,","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3549"}},{"Add":{"text":" };","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3556"}},{"Add":{"text":"}","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3558"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3559"}}]}},{"Edit":{"inode":{"change":2,"pos":4360},"path":"t/TaskDispatcher.t","line":61,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":5581}],"down_context":[{"change":2,"pos":5581}],"flag":"BLOCK","start":3561,"end":4098,"inode":{"change":2,"pos":4360}}},"contents":[{"Add":{"text":"}","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3562"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3563"}},{"Add":{"text":"sub make_fake_record {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3586"}},{"Add":{"text":" my %attrs = @_;","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3605"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3606"}},{"Add":{"text":" my $record = {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3625"}},{"Add":{"text":" \"attempts\" => $attrs{\"attempts\"} || 0,","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3672"}},{"Add":{"text":" \"requeued\" => 0,","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3697"}},{"Add":{"text":" \"deleted\" => 0","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3720"}},{"Add":{"text":" };","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3727"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3728"}},{"Add":{"text":" my $mock_record = mock_obj $record => (","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3772"}},{"Add":{"text":" add => [","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3789"}},{"Add":{"text":" \"delete\" => sub {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3819"}},{"Add":{"text":" my ($self, $db, $plugin) = @_;","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3866"}},{"Add":{"text":" $self->{\"deleted\"} = 1;","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3906"}},{"Add":{"text":" },","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3921"}},{"Add":{"text":" \"requeue\" => sub {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3952"}},{"Add":{"text":" my ($self, $db, $plugin) = @_;","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:3999"}},{"Add":{"text":" $self->{\"requeued\"} = 1;","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4040"}},{"Add":{"text":" }","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4054"}},{"Add":{"text":" ]","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4064"}},{"Add":{"text":" );","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4071"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4072"}},{"Add":{"text":" return $mock_record;","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4097"}}]}},{"Edit":{"inode":{"change":2,"pos":4360},"path":"t/TaskDispatcher.t","line":132,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":7147}],"down_context":[{"change":2,"pos":7147}],"flag":"BLOCK","start":4099,"end":4100,"inode":{"change":2,"pos":4360}}},"contents":[{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4099"}}]}},{"Edit":{"inode":{"change":2,"pos":4360},"path":"t/TaskDispatcher.t","line":144,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":7709}],"down_context":[{"change":2,"pos":7709}],"flag":"BLOCK","start":4101,"end":5960,"inode":{"change":2,"pos":4360}}},"contents":[{"Add":{"text":" };","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4107"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4108"}},{"Add":{"text":" subtest \"a failed run without a record saves the task for later\" => sub {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4186"}},{"Add":{"text":" my $db = \"bogus db\";","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4215"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4216"}},{"Add":{"text":" my $record = make_fake_record();","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4257"}},{"Add":{"text":" my $bogus_plugin = make_noop_plugin(\"bogus-1\");","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4313"}},{"Add":{"text":" my $task = {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4334"}},{"Add":{"text":" \"event\" => make_failing_event(\"fail-event\"),","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4391"}},{"Add":{"text":" \"plugin_name\" => ref $bogus_plugin,","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4439"}},{"Add":{"text":" \"record\" => undef,","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4470"}},{"Add":{"text":" };","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4481"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4482"}},{"Add":{"text":" my $save_hook_called = 0;","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4516"}},{"Add":{"text":" my $dispatcher = Hydra::TaskDispatcher->new($db, $prometheus, [$bogus_plugin],","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4603"}},{"Add":{"text":" sub {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4621"}},{"Add":{"text":" $save_hook_called = 1;","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4660"}},{"Add":{"text":" }","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4674"}},{"Add":{"text":" );","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4685"}},{"Add":{"text":" $dispatcher->dispatch_task($task);","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4728"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4729"}},{"Add":{"text":" is($save_hook_called, 1, \"The record was requeued with the store hook.\");","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4811"}},{"Add":{"text":" };","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4818"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4819"}},{"Add":{"text":" subtest \"a successful run from a record deletes the record\" => sub {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4892"}},{"Add":{"text":" my $db = \"bogus db\";","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4921"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4922"}},{"Add":{"text":" my $record = make_fake_record();","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:4963"}},{"Add":{"text":" my $bogus_plugin = make_noop_plugin(\"bogus-1\");","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5019"}},{"Add":{"text":" my $task = {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5040"}},{"Add":{"text":" \"event\" => make_fake_event(\"success-event\"),","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5097"}},{"Add":{"text":" \"plugin_name\" => ref $bogus_plugin,","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5145"}},{"Add":{"text":" \"record\" => $record,","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5178"}},{"Add":{"text":" };","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5189"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5190"}},{"Add":{"text":" my $dispatcher = Hydra::TaskDispatcher->new($db, $prometheus, [$bogus_plugin]);","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5278"}},{"Add":{"text":" $dispatcher->dispatch_task($task);","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5321"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5322"}},{"Add":{"text":" is($record->{\"deleted\"}, 1, \"The record was deleted.\");","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5386"}},{"Add":{"text":" };","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5393"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5394"}},{"Add":{"text":" subtest \"a failed run from a record re-queues the task\" => sub {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5463"}},{"Add":{"text":" my $db = \"bogus db\";","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5492"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5493"}},{"Add":{"text":" my $record = make_fake_record();","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5534"}},{"Add":{"text":" my $bogus_plugin = make_noop_plugin(\"bogus-1\");","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5590"}},{"Add":{"text":" my $task = {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5611"}},{"Add":{"text":" \"event\" => make_failing_event(\"fail-event\"),","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5668"}},{"Add":{"text":" \"plugin_name\" => ref $bogus_plugin,","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5716"}},{"Add":{"text":" \"record\" => $record,","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5749"}},{"Add":{"text":" };","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5760"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5761"}},{"Add":{"text":" my $dispatcher = Hydra::TaskDispatcher->new($db, $prometheus, [$bogus_plugin]);","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5849"}},{"Add":{"text":" $dispatcher->dispatch_task($task);","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5892"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5893"}},{"Add":{"text":" is($record->{\"requeued\"}, 1, \"The record was requeued.\");","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5959"}}]}},{"Edit":{"inode":{"change":2,"pos":4360},"path":"t/TaskDispatcher.t","line":201,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":7716}],"down_context":[{"change":2,"pos":7716}],"flag":"BLOCK","start":5961,"end":6569,"inode":{"change":2,"pos":4360}}},"contents":[{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:5961"}},{"Add":{"text":" subtest \"a failed run from a record with a lot of attempts deletes the task\" => sub {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:6051"}},{"Add":{"text":" my $db = \"bogus db\";","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:6080"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:6081"}},{"Add":{"text":" my $record = make_fake_record(attempts => 101);","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:6137"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:6138"}},{"Add":{"text":" my $bogus_plugin = make_noop_plugin(\"bogus-1\");","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:6194"}},{"Add":{"text":" my $task = {","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:6215"}},{"Add":{"text":" \"event\" => make_failing_event(\"fail-event\"),","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:6272"}},{"Add":{"text":" \"plugin_name\" => ref $bogus_plugin,","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:6320"}},{"Add":{"text":" \"record\" => $record,","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:6353"}},{"Add":{"text":" };","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:6364"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:6365"}},{"Add":{"text":" my $dispatcher = Hydra::TaskDispatcher->new($db, $prometheus, [$bogus_plugin]);","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:6453"}},{"Add":{"text":" $dispatcher->dispatch_task($task);","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:6496"}},{"Add":{"text":"","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:6497"}},{"Add":{"text":" is($record->{\"deleted\"}, 1, \"The record was deleted.\");","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:6561"}},{"Add":{"text":" };","pos":"I7Q3M7V32AUNVHKPCRAMSOIZXSTTOOPZ2PR3A2UF4J7KRDGIWWOQC:6568"}}]}}],"owner":"grahamc","repo":"hydra","token":"7wWriv6l7jmN/k1krzvKnweBzYCiSEZ5wlmcvtV2Mfo=","login":null}

…

Dependencies

Change contents

Review