2 # Batch EXecutor 3.0 -- Show Queued Jobs
3 # (c) 2011-2012 Martin Mares <mj@ucw.cz>
22 Usage: bex queue [<options and actions>] [[!]<machine-or-class> ...]
25 --by-job Show jobs sorted by job ID (default)
26 -h, --by-host Show jobs sorted by host
27 --rm Remove jobs from the queue
28 --move-to=<queue> Move jobs to a different queue
31 -j, --job=<id> Act on the specified job (default: on all)
32 -q, --queue=<name> Act on the given queue
33 -s, --summary Show only a summary
38 Getopt::Long::Configure("bundling");
40 "by-job!" => \$op_by_job,
41 "h|by-host!" => \$op_by_host,
43 "move-to=s" => \$op_move_to,
44 "j|job=s" => \$given_job,
45 "q|queue=s" => \$queue_name,
46 "s|summary!" => \$summary,
48 ) or die "Try `bex queue --help' for more information.\n";
50 my @machines = BEX::Config::parse_machine_list(@ARGV ? @ARGV : '*');
51 my $queue = BEX::Queue->new($queue_name);
56 for my $m (@machines) {
57 for my $j ($queue->scan($m)) {
58 if (defined $given_job) {
59 next if $j ne $given_job;
61 push @{$jobs{$j}}, $m;
62 push @{$machs{$m}}, $j;
70 my $ops = 0 + defined($op_by_host) + defined($op_by_job) + defined($op_rm) + defined($op_move_to);
71 if ($ops > 1) { die "Multiple actions are not allowed\n"; }
73 if ($op_rm) { do_rm(); }
74 elsif (defined $op_move_to) { do_move_to(); }
84 for my $m (keys %machs) {
85 $mach_locked{$m} = $queue->is_locked($m, undef);
86 for my $j (@{$machs{$m}}) {
87 my $st = $queue->read_job_status($m, $j);
88 my $s = $st->{"Status"} // "UNKNOWN";
89 $cnt_by_job{$j}{$s}++;
90 $cnt_by_mach{$m}{$s}++;
91 if (defined($st->{'Time'}) && defined($st->{'Status'})) {
92 $stat{$m}{$j} = ' [' . $st->{'Status'} . ' on ' .
93 POSIX::strftime('%Y-%m-%d', localtime $st->{'Time'}) . ']';
97 if ($mach_locked{$m} || $queue->is_locked($m, $j)) {
98 $stat{$m}{$j} .= ' [LOCKED]';
103 if ($queue->is_locked(undef, undef)) {
104 print "### Queue lock present\n\n";
109 for my $m (sort keys %cnt_by_mach) {
110 print "$m: ", join(" ", map { "$_:" . $cnt_by_mach{$m}{$_} } sort keys %{$cnt_by_mach{$m}}), "\n";
113 for my $j (sort keys %cnt_by_job) {
114 print $queue->job_name($j), ": ", join(" ", map { "$_:" . $cnt_by_job{$j}{$_} } sort keys %{$cnt_by_job{$j}}), "\n";
119 for my $m (sort keys %machs) {
120 print "$m", ($mach_locked{$m} ? ' [LOCKED]' : ''), "\n";
121 for my $j (@{$machs{$m}}) {
122 print "\t" . $queue->job_name($j) . $stat{$m}{$j}, "\n";
126 for my $j (sort keys %jobs) {
127 print $queue->job_name($j), "\n";
128 for my $m (sort @{$jobs{$j}}) {
129 print "\t$m", $stat{$m}{$j}, "\n";
139 for my $m (sort keys %machs) {
140 for my $j (sort @{$machs{$m}}) {
141 if (!$queue->lock($m, $j)) {
142 print STDERR "Cannot remove $m:", $queue->job_name($j), ", it is locked\n";
145 $queue->update_job_status($m, $j, 'REMOVED');
146 $queue->remove($m, $j);
147 print "Removed $m:", $queue->job_name($j), "\n";
158 my $dest = BEX::Queue->new($op_move_to);
159 $dest->{'Name'} ne $queue->{'Name'} or die "Moving to the same queue is not permitted\n";
160 for my $j (sort keys %jobs) {
161 my $job = BEX::Job->new_from_file($queue->job_file($j));
162 for my $m (sort @{$jobs{$j}}) {
163 if (!$queue->lock($m, $j)) {
164 print STDERR "Cannot move $m:", $queue->job_name($j), ", it is locked\n";
167 my $enq = $dest->enqueue($m, $job);
169 $dest->update_job_status($m, $job->id, 'NEW', 'Moved to this queue');
171 $dest->log($m, $job->id, 'REQUEUE', 'Moved to this queue');
173 $queue->update_job_status($m, $job->id, 'REMOVED', 'Moved from this queue');
174 $queue->remove($m, $j);
175 print "Moved $m:", $dest->job_name($j);
176 print " (already queued)" if !$enq;