end
def queue
+ params[:order] ||= ['priority desc', 'created_at']
+ load_limit_offset_order_params
load_where_param
@where.merge!({
started_at: nil,
cancelled_at: nil,
success: nil
})
- params[:order] ||= ['priority desc', 'created_at']
+ load_filters_param
find_objects_for_index
index
end
running: 1
done: 0
runtime_constraints: {}
+
+queued:
+ uuid: zzzzz-8i9sb-grx15v5mjnsyxk7
+ owner_uuid: zzzzz-tpzed-xurymjxw79nv3jz
+ cancelled_at: ~
+ cancelled_by_user_uuid: ~
+ cancelled_by_client_uuid: ~
+ started_at: ~
+ finished_at: ~
+ script: foo
+ script_version: 1de84a854e2b440dc53bf42f8548afa4c17da332
+ script_parameters: {}
+ running: ~
+ success: ~
+ output: ~
+ priority: ~
+ log: ~
+ is_locked_by_uuid: ~
+ tasks_summary: {}
+ runtime_constraints: {}
assert_response :success
end
+ [:active, :admin].each do |which_token|
+ test "get job queue as #{which_token} user" do
+ authorize_with which_token
+ get :queue
+ assert_response :success
+ assert_operator 1, :<=, assigns(:objects).count
+ end
+ test "get job queue as #{which_token} user, with a filter" do
+ authorize_with which_token
+ get :queue, { filters: [['script','=','foo']] }
+ assert_response :success
+ assert_equal ['foo'], assigns(:objects).collect(&:script).uniq
+ end
+ end
+
end