projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch 'master' into 3583-provenance-graph-issue
[arvados.git]
/
services
/
api
/
app
/
controllers
/
arvados
/
v1
/
jobs_controller.rb
diff --git
a/services/api/app/controllers/arvados/v1/jobs_controller.rb
b/services/api/app/controllers/arvados/v1/jobs_controller.rb
index 7b3b6586f68a1e0bb86383cef6f4c7e5e006a61e..901b7423e4965eedef8e20e8e1b5fd868b55c27a 100644
(file)
--- a/
services/api/app/controllers/arvados/v1/jobs_controller.rb
+++ b/
services/api/app/controllers/arvados/v1/jobs_controller.rb
@@
-65,9
+65,9
@@
class Arvados::V1::JobsController < ApplicationController
incomplete_job = nil
@objects.each do |j|
if j.nondeterministic != true and
incomplete_job = nil
@objects.each do |j|
if j.nondeterministic != true and
-
((j.success == true and j.output != nil) or j.running == tru
e) and
+
["Queued", "Running", "Complete"].include?(j.stat
e) and
j.script_parameters == resource_attrs[:script_parameters]
j.script_parameters == resource_attrs[:script_parameters]
- if j.
running
&& j.owner_uuid == current_user.uuid
+ if j.
state != "Complete"
&& j.owner_uuid == current_user.uuid
# We'll use this if we don't find a job that has completed
incomplete_job ||= j
else
# We'll use this if we don't find a job that has completed
incomplete_job ||= j
else
@@
-100,6
+100,11
@@
class Arvados::V1::JobsController < ApplicationController
show
end
show
end
+ def lock
+ @object.lock current_user.uuid
+ show
+ end
+
class LogStreamer
Q_UPDATE_INTERVAL = 12
def initialize(job, opts={})
class LogStreamer
Q_UPDATE_INTERVAL = 12
def initialize(job, opts={})
@@
-151,12
+156,7
@@
class Arvados::V1::JobsController < ApplicationController
params[:order] ||= ['priority desc', 'created_at']
load_limit_offset_order_params
load_where_param
params[:order] ||= ['priority desc', 'created_at']
load_limit_offset_order_params
load_where_param
- @where.merge!({
- started_at: nil,
- is_locked_by_uuid: nil,
- cancelled_at: nil,
- success: nil
- })
+ @where.merge!({state: Job::Queued})
return if false.equal?(load_filters_param)
find_objects_for_index
index
return if false.equal?(load_filters_param)
find_objects_for_index
index
@@
-164,7
+164,8
@@
class Arvados::V1::JobsController < ApplicationController
def queue_size
# Users may not be allowed to see all the jobs in the queue, so provide a
def queue_size
# Users may not be allowed to see all the jobs in the queue, so provide a
- # method to get the actual queue length.
+ # method to get just the queue size in order to get a gist of how busy the
+ # cluster is.
render :json => {:queue_size => Job.queue.size}
end
render :json => {:queue_size => Job.queue.size}
end