1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
|
package Minion::Command::minion::worker;
use Mojo::Base 'Mojolicious::Command';
use Mojo::Util 'getopt';
has description => 'Start Minion worker';
has usage => sub { shift->extract_usage };
sub run {
my ($self, @args) = @_;
my $worker = $self->app->minion->worker;
my $status = $worker->status;
getopt \@args,
'C|command-interval=i' => \$status->{command_interval},
'D|dequeue-timeout=i' => \$status->{dequeue_timeout},
'I|heartbeat-interval=i' => \$status->{heartbeat_interval},
'j|jobs=i' => \$status->{jobs},
'q|queue=s' => \my @queues,
'R|repair-interval=i' => \$status->{repair_interval};
$status->{queues} = \@queues if @queues;
my $log = $self->app->log;
$log->info("Worker $$ started");
$worker->on(dequeue => sub { pop->once(spawn => \&_spawn) });
$worker->run;
$log->info("Worker $$ stopped");
}
sub _spawn {
my ($job, $pid) = @_;
my ($id, $task) = ($job->id, $job->task);
$job->app->log->debug(
qq{Process $pid is performing job "$id" with task "$task"});
}
1;
=encoding utf8
=head1 NAME
Minion::Command::minion::worker - Minion worker command
=head1 SYNOPSIS
Usage: APPLICATION minion worker [OPTIONS]
./myapp.pl minion worker
./myapp.pl minion worker -m production -I 15 -C 5 -R 3600 -j 10
./myapp.pl minion worker -q important -q default
Options:
-C, --command-interval <seconds> Worker remote control command interval,
defaults to 10
-D, dequeue-timeout <seconds> Maximum amount of time to wait for
jobs, defaults to 5
-h, --help Show this summary of available options
--home <path> Path to home directory of your
application, defaults to the value of
MOJO_HOME or auto-detection
-I, --heartbeat-interval <seconds> Heartbeat interval, defaults to 300
-j, --jobs <number> Maximum number of jobs to perform
parallel in forked worker processes,
defaults to 4
-m, --mode <name> Operating mode for your application,
defaults to the value of
MOJO_MODE/PLACK_ENV or "development"
-q, --queue <name> One or more queues to get jobs from,
defaults to "default"
-R, --repair-interval <seconds> Repair interval, up to half of this
value can be subtracted randomly to
make sure not all workers repair at the
same time, defaults to 21600 (6 hours)
=head1 DESCRIPTION
L<Minion::Command::minion::worker> starts a L<Minion> worker. You can have as
many workers as you like.
=head1 WORKER SIGNALS
The L<Minion::Command::minion::worker> process can be controlled at runtime
with the following signals.
=head2 INT, TERM
Stop gracefully after finishing the current jobs.
=head2 QUIT
Stop immediately without finishing the current jobs.
=head1 JOB SIGNALS
The job processes spawned by the L<Minion::Command::minion::worker> process can
be controlled at runtime with the following signals.
=head2 INT
This signal starts out with the operating system default and allows for jobs to
install a custom signal handler to stop gracefully.
=head2 USR1, USR2
These signals start out being ignored and allow for jobs to install custom
signal handlers.
=head1 REMOTE CONTROL COMMANDS
The L<Minion::Command::minion::worker> process can be controlled at runtime
through L<Minion::Command::minion::job>, from anywhere in the network, by
broadcasting the following remote control commands.
=head2 jobs
$ ./myapp.pl minion job -b jobs -a '[10]'
$ ./myapp.pl minion job -b jobs -a '[10]' 23
Instruct one or more workers to change the number of jobs to perform
concurrently. Setting this value to C<0> will effectively pause the worker. That
means all current jobs will be finished, but no new ones accepted, until the
number is increased again.
=head2 kill
$ ./myapp.pl minion job -b kill -a '["INT", 10025]'
$ ./myapp.pl minion job -b kill -a '["INT", 10025]' 23
Instruct one or more workers to send a signal to a job that is currently being
performed. This command will be ignored by workers that do not have a job
matching the id. That means it is safe to broadcast this command to all workers.
=head2 stop
$ ./myapp.pl minion job -b stop -a '[10025]'
$ ./myapp.pl minion job -b stop -a '[10025]' 23
Instruct one or more workers to stop a job that is currently being performed
immediately. This command will be ignored by workers that do not have a job
matching the id. That means it is safe to broadcast this command to all workers.
=head1 ATTRIBUTES
L<Minion::Command::minion::worker> inherits all attributes from
L<Mojolicious::Command> and implements the following new ones.
=head2 description
my $description = $worker->description;
$worker = $worker->description('Foo');
Short description of this command, used for the command list.
=head2 usage
my $usage = $worker->usage;
$worker = $worker->usage('Foo');
Usage information for this command, used for the help screen.
=head1 METHODS
L<Minion::Command::minion::worker> inherits all methods from
L<Mojolicious::Command> and implements the following new ones.
=head2 run
$worker->run(@ARGV);
Run this command.
=head1 SEE ALSO
L<Minion>, L<Mojolicious::Guides>, L<https://mojolicious.org>.
=cut
|
