Skip to content
This repository was archived by the owner on Oct 16, 2025. It is now read-only.

Commit 317e5ca

Browse files
committed
eliminate requeue special
1 parent a731c4b commit 317e5ca

File tree

3 files changed

+0
-50
lines changed

3 files changed

+0
-50
lines changed

src-colladmin/actions/zookeeper_action.rb

Lines changed: 0 additions & 36 deletions
Original file line numberDiff line numberDiff line change
@@ -346,42 +346,6 @@ def perform_action
346346
end
347347
end
348348

349-
## Queue manipulation action using new mrt-zk - special handling to skip downloading
350-
class ZkRequeueSpecialAction < ZkAction
351-
def perform_action
352-
if @qpath =~ /access/
353-
acc = MerrittZK::Access.new(get_access_queue, get_id)
354-
acc.load(@zk)
355-
acc.set_status(@zk, MerrittZK::AccessState::Pending)
356-
{ message: "Acc #{acc.id} requeued " }.to_json
357-
else
358-
job = MerrittZK::Job.new(get_id)
359-
job.load(@zk)
360-
js = job.json_property(@zk, MerrittZK::ZkKeys::STATUS)
361-
laststat = js.fetch(:last_successful_status, '')
362-
363-
job.lock(@zk)
364-
365-
case laststat
366-
when 'Pending', '', nil
367-
job.set_status(@zk, MerrittZK::JobState::Estimating, job_retry: true)
368-
when 'Estimating'
369-
job.set_status(@zk, MerrittZK::JobState::Provisioning, job_retry: true)
370-
when 'Provisioning' || 'Downloading'
371-
job.set_status(@zk, MerrittZK::JobState::Processing, job_retry: true)
372-
when 'Processing'
373-
job.set_status(@zk, MerrittZK::JobState::Recording, job_retry: true)
374-
when 'Recording'
375-
job.set_status(@zk, MerrittZK::JobState::Notify, job_retry: true)
376-
end
377-
378-
job.unlock(@zk)
379-
380-
{ message: "Job #{job.id} requeued to status #{job.status_name}" }.to_json
381-
end
382-
end
383-
end
384-
385349
## Queue manipulation action using new mrt-zk
386350
class ZkDeleteAction < ZkAction
387351
def perform_action

src-colladmin/config/actions.yml

Lines changed: 0 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -1004,18 +1004,6 @@ orphan-delete:
10041004
- requeue
10051005
documentation: |
10061006
ZK tbd
1007-
requeue-special-mrtzk:
1008-
link-title: Re-queue an item from a Zookeeper queue
1009-
class: ZkRequeueSpecialAction
1010-
category: Queue Management
1011-
sensitivity: irreversible change
1012-
testing: manual
1013-
description: |
1014-
Re-queue an item from a Zookeeper queue.
1015-
report-datatypes:
1016-
- requeue
1017-
documentation: |
1018-
ZK tbd
10191007
hold-queue-item-mrtzk:
10201008
link-title: Move a pending item from in Zookeeper queue to a Held status
10211009
class: ZkHoldAction

src-common/template/api-table.js

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -794,8 +794,6 @@ function format(cell, v, type, merritt_path) {
794794
} else if (type == 'requeue-mrtzk' && v != '') {
795795
p = colladmin_root + "/lambda?path=requeue-mrtzk&queue-path="+v;
796796
makeLink(cell, 'Requeue', "javascript:ajax_invoke('"+encodeURIComponent(p)+"');testRequeue()").addClass("ajax");
797-
p = colladmin_root + "/lambda?path=requeue-special-mrtzk&queue-path="+v;
798-
makeLink(cell, 'Requeue Special', "javascript:ajax_invoke('"+encodeURIComponent(p)+"');testRequeue()").addClass("ajax");
799797
} else if (type == 'hold' && v != '') {
800798
p = colladmin_root + "/lambda?path=hold-queue-item&queue-path="+v;
801799
makeLink(cell, 'Hold', "javascript:ajax_invoke('"+encodeURIComponent(p)+"')").addClass("ajax");

0 commit comments

Comments
 (0)