diff --git a/scripts/lsf_beekeeper.pl b/scripts/lsf_beekeeper.pl index 6bcc1fdbf52a8cbefd4634c8e28db1d5668fafea..2ba408ae022ba92d364bcabf654f515196a4d072 100755 --- a/scripts/lsf_beekeeper.pl +++ b/scripts/lsf_beekeeper.pl @@ -108,6 +108,7 @@ if($loopit) { #sync and show stats $queen->synchronize_hive() if($sync); $queen->print_hive_status if($self->{'showStatus'}); + show_running_workers($self, $queen); $queen->get_num_needed_workers(); # show_overdue_workers($self, $queen); } @@ -208,12 +209,30 @@ sub show_overdue_workers { my $queen = shift; print("===== overdue workers\n"); - my $overdueWorkers = $queen->fetch_overdue_workers(75*60); + my $overdueWorkers = $queen->fetch_overdue_workers($self->{'overdue_limit'}*60); foreach my $worker (@{$overdueWorkers}) { printf("%10d %35s %15s %20s(%d)\n", $worker->hive_id,$worker->host,$worker->process_id, $worker->analysis->logic_name, $worker->analysis->dbID); } } +sub show_running_workers { + my $self = shift; + my $queen = shift; + + print("===== running workers\n"); + my $worker_list = $queen->fetch_overdue_workers(0); + foreach my $worker (@{$worker_list}) { + printf("%10d %30s(%5d) %5s:%15s %15s (%s)\n", + $worker->hive_id, + $worker->analysis->logic_name, + $worker->analysis->dbID, + $worker->beekeeper, + $worker->process_id, + $worker->host, + $worker->last_check_in); + } +} + sub run_autonomously { my $self = shift;