Hello community, here is the log from the commit of package perl-Minion for openSUSE:Factory checked in at 2015-11-11 10:31:48 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ Comparing /work/SRC/openSUSE:Factory/perl-Minion (Old) and /work/SRC/openSUSE:Factory/.perl-Minion.new (New) ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Package is "perl-Minion" Changes: -------- --- /work/SRC/openSUSE:Factory/perl-Minion/perl-Minion.changes 2015-11-08 11:26:10.000000000 +0100 +++ /work/SRC/openSUSE:Factory/.perl-Minion.new/perl-Minion.changes 2015-11-11 10:36:07.000000000 +0100 @@ -1,0 +2,9 @@ +Mon Nov 9 09:55:00 UTC 2015 - [email protected] + +- updated to 3.03 + see /usr/share/doc/packages/perl-Minion/Changes + + 3.03 2015-11-08 + - Added queues option to perform_jobs method in Minion. + +------------------------------------------------------------------- Old: ---- Minion-3.02.tar.gz New: ---- Minion-3.03.tar.gz ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++ Other differences: ------------------ ++++++ perl-Minion.spec ++++++ --- /var/tmp/diff_new_pack.GGKdoK/_old 2015-11-11 10:36:08.000000000 +0100 +++ /var/tmp/diff_new_pack.GGKdoK/_new 2015-11-11 10:36:08.000000000 +0100 @@ -17,7 +17,7 @@ Name: perl-Minion -Version: 3.02 +Version: 3.03 Release: 0 %define cpan_name Minion Summary: Job queue ++++++ Minion-3.02.tar.gz -> Minion-3.03.tar.gz ++++++ diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/Minion-3.02/Changes new/Minion-3.03/Changes --- old/Minion-3.02/Changes 2015-10-30 18:23:55.000000000 +0100 +++ new/Minion-3.03/Changes 2015-11-08 10:45:42.000000000 +0100 @@ -1,4 +1,7 @@ +3.03 2015-11-08 + - Added queues option to perform_jobs method in Minion. + 3.02 2015-10-31 - Fixed portability issues in tests. diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/Minion-3.02/META.json new/Minion-3.03/META.json --- old/Minion-3.02/META.json 2015-10-30 18:25:48.000000000 +0100 +++ new/Minion-3.03/META.json 2015-11-08 10:46:53.000000000 +0100 @@ -54,5 +54,5 @@ }, "x_IRC" : "irc://irc.perl.org/#mojo" }, - "version" : "3.02" + "version" : "3.03" } diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/Minion-3.02/META.yml new/Minion-3.03/META.yml --- old/Minion-3.02/META.yml 2015-10-30 18:25:48.000000000 +0100 +++ new/Minion-3.03/META.yml 2015-11-08 10:46:53.000000000 +0100 @@ -27,4 +27,4 @@ homepage: http://mojolicio.us license: http://www.opensource.org/licenses/artistic-license-2.0 repository: https://github.com/kraih/minion.git -version: '3.02' +version: '3.03' diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/Minion-3.02/lib/Minion.pm new/Minion-3.03/lib/Minion.pm --- old/Minion-3.02/lib/Minion.pm 2015-10-30 05:14:04.000000000 +0100 +++ new/Minion-3.03/lib/Minion.pm 2015-11-08 10:43:36.000000000 +0100 @@ -16,7 +16,7 @@ has remove_after => 864000; has tasks => sub { {} }; -our $VERSION = '3.02'; +our $VERSION = '3.03'; sub add_task { ($_[0]->tasks->{$_[1]} = $_[2]) and return $_[0] } @@ -50,9 +50,9 @@ } sub perform_jobs { - my $self = shift; + my ($self, $options) = @_; my $worker = $self->worker; - while (my $job = $worker->register->dequeue(0)) { $job->perform } + while (my $job = $worker->register->dequeue(0, $options)) { $job->perform } $worker->unregister; } @@ -348,9 +348,22 @@ =head2 perform_jobs $minion->perform_jobs; + $minion->perform_jobs({queues => ['important']}); Perform all jobs, very useful for testing. +These options are currently available: + +=over 2 + +=item queues + + queues => ['important'] + +One or more queues to dequeue jobs from, defaults to C<default>. + +=back + =head2 repair $minion = $minion->repair; diff -urN '--exclude=CVS' '--exclude=.cvsignore' '--exclude=.svn' '--exclude=.svnignore' old/Minion-3.02/t/pg_lite_app.t new/Minion-3.03/t/pg_lite_app.t --- old/Minion-3.02/t/pg_lite_app.t 2015-10-30 18:20:08.000000000 +0100 +++ new/Minion-3.03/t/pg_lite_app.t 2015-11-08 10:44:59.000000000 +0100 @@ -36,9 +36,9 @@ ); get '/add' => sub { - my $c = shift; - my $id - = $c->minion->enqueue(add => [$c->param('first'), $c->param('second')]); + my $c = shift; + my $id = $c->minion->enqueue( + add => [$c->param('first'), $c->param('second')] => {queue => 'test'}); $c->render(text => $id); }; @@ -51,14 +51,15 @@ # Perform jobs automatically $t->get_ok('/add' => form => {first => 1, second => 2})->status_is(200); -$t->app->minion->perform_jobs; +$t->app->minion->perform_jobs({queues => ['test']}); $t->get_ok('/result' => form => {id => $t->tx->res->text})->status_is(200) ->content_is('3'); $t->get_ok('/add' => form => {first => 2, second => 3})->status_is(200); my $first = $t->tx->res->text; $t->get_ok('/add' => form => {first => 4, second => 5})->status_is(200); my $second = $t->tx->res->text; -Mojo::IOLoop->delay(sub { $t->app->minion->perform_jobs })->wait; +Mojo::IOLoop->delay(sub { $t->app->minion->perform_jobs({queues => ['test']}) }) + ->wait; $t->get_ok('/result' => form => {id => $first})->status_is(200) ->content_is('5'); $t->get_ok('/result' => form => {id => $second})->status_is(200)
