services/api/test/functional/arvados/v1/jobs_controller_test.rb

   1 require 'test_helper'
   2 load 'test/functional/arvados/v1/git_setup.rb'
   3
   4 class Arvados::V1::JobsControllerTest < ActionController::TestCase
   5
   6   include GitSetup
   7
   8   test "submit a job" do
   9     authorize_with :active
  10     post :create, job: {
  11       script: "hash",
  12       script_version: "master",
  13       repository: "foo",
  14       script_parameters: {}
  15     }
  16     assert_response :success
  17     assert_not_nil assigns(:object)
  18     new_job = JSON.parse(@response.body)
  19     assert_not_nil new_job['uuid']
  20     assert_not_nil new_job['script_version'].match(/^[0-9a-f]{40}$/)
  21     # Default: not persistent
  22     assert_equal false, new_job['output_is_persistent']
  23   end
  24
  25   test "normalize output and log uuids when creating job" do
  26     authorize_with :active
  27     post :create, job: {
  28       script: "hash",
  29       script_version: "master",
  30       script_parameters: {},
  31       repository: "foo",
  32       started_at: Time.now,
  33       finished_at: Time.now,
  34       running: false,
  35       success: true,
  36       output: 'd41d8cd98f00b204e9800998ecf8427e+0+K@xyzzy',
  37       log: 'd41d8cd98f00b204e9800998ecf8427e+0+K@xyzzy'
  38     }
  39     assert_response :success
  40     assert_not_nil assigns(:object)
  41     new_job = JSON.parse(@response.body)
  42     assert_equal 'd41d8cd98f00b204e9800998ecf8427e+0', new_job['log']
  43     assert_equal 'd41d8cd98f00b204e9800998ecf8427e+0', new_job['output']
  44     version = new_job['script_version']
  45
  46     # Make sure version doesn't get mangled by normalize
  47     assert_not_nil version.match(/^[0-9a-f]{40}$/)
  48     put :update, {
  49       id: new_job['uuid'],
  50       job: {
  51         log: new_job['log']
  52       }
  53     }
  54     assert_equal version, JSON.parse(@response.body)['script_version']
  55   end
  56
  57   test "cancel a running job" do
  58     # We need to verify that "cancel" creates a trigger file, so first
  59     # let's make sure there is no stale trigger file.
  60     begin
  61       File.unlink(Rails.configuration.crunch_refresh_trigger)
  62     rescue Errno::ENOENT
  63     end
  64
  65     authorize_with :active
  66     put :update, {
  67       id: jobs(:running).uuid,
  68       job: {
  69         cancelled_at: 4.day.ago
  70       }
  71     }
  72     assert_response :success
  73     assert_not_nil assigns(:object)
  74     job = JSON.parse(@response.body)
  75     assert_not_nil job['uuid']
  76     assert_not_nil job['cancelled_at']
  77     assert_not_nil job['cancelled_by_user_uuid']
  78     assert_not_nil job['cancelled_by_client_uuid']
  79     assert_equal(true, Time.parse(job['cancelled_at']) > 1.minute.ago,
  80                  'server should correct bogus cancelled_at ' +
  81                  job['cancelled_at'])
  82     assert_equal(true,
  83                  File.exists?(Rails.configuration.crunch_refresh_trigger),
  84                  'trigger file should be created when job is cancelled')
  85
  86     put :update, {
  87       id: jobs(:running).uuid,
  88       job: {
  89         cancelled_at: nil
  90       }
  91     }
  92     job = JSON.parse(@response.body)
  93     assert_not_nil job['cancelled_at'], 'un-cancelled job stays cancelled'
  94   end
  95
  96   test "update a job without failing script_version check" do
  97     authorize_with :admin
  98     put :update, {
  99       id: jobs(:uses_nonexistent_script_version).uuid,
 100       job: {
 101         owner_uuid: users(:admin).uuid
 102       }
 103     }
 104     assert_response :success
 105     put :update, {
 106       id: jobs(:uses_nonexistent_script_version).uuid,
 107       job: {
 108         owner_uuid: users(:active).uuid
 109       }
 110     }
 111     assert_response :success
 112   end
 113
 114   test "search jobs by uuid with >= query" do
 115     authorize_with :active
 116     get :index, {
 117       filters: [['uuid', '>=', 'zzzzz-8i9sb-pshmckwoma9plh7']]
 118     }
 119     assert_response :success
 120     found = assigns(:objects).collect(&:uuid)
 121     assert_equal true, !!found.index('zzzzz-8i9sb-pshmckwoma9plh7')
 122     assert_equal false, !!found.index('zzzzz-8i9sb-4cf0nhn6xte809j')
 123   end
 124
 125   test "search jobs by uuid with <= query" do
 126     authorize_with :active
 127     get :index, {
 128       filters: [['uuid', '<=', 'zzzzz-8i9sb-pshmckwoma9plh7']]
 129     }
 130     assert_response :success
 131     found = assigns(:objects).collect(&:uuid)
 132     assert_equal true, !!found.index('zzzzz-8i9sb-pshmckwoma9plh7')
 133     assert_equal true, !!found.index('zzzzz-8i9sb-4cf0nhn6xte809j')
 134   end
 135
 136   test "search jobs by uuid with >= and <= query" do
 137     authorize_with :active
 138     get :index, {
 139       filters: [['uuid', '>=', 'zzzzz-8i9sb-pshmckwoma9plh7'],
 140               ['uuid', '<=', 'zzzzz-8i9sb-pshmckwoma9plh7']]
 141     }
 142     assert_response :success
 143     found = assigns(:objects).collect(&:uuid)
 144     assert_equal found, ['zzzzz-8i9sb-pshmckwoma9plh7']
 145   end
 146
 147   test "search jobs by uuid with < query" do
 148     authorize_with :active
 149     get :index, {
 150       filters: [['uuid', '<', 'zzzzz-8i9sb-pshmckwoma9plh7']]
 151     }
 152     assert_response :success
 153     found = assigns(:objects).collect(&:uuid)
 154     assert_equal false, !!found.index('zzzzz-8i9sb-pshmckwoma9plh7')
 155     assert_equal true, !!found.index('zzzzz-8i9sb-4cf0nhn6xte809j')
 156   end
 157
 158   test "search jobs by uuid with like query" do
 159     authorize_with :active
 160     get :index, {
 161       filters: [['uuid', 'like', '%hmckwoma9pl%']]
 162     }
 163     assert_response :success
 164     found = assigns(:objects).collect(&:uuid)
 165     assert_equal found, ['zzzzz-8i9sb-pshmckwoma9plh7']
 166   end
 167
 168   test "search jobs by uuid with 'in' query" do
 169     authorize_with :active
 170     get :index, {
 171       filters: [['uuid', 'in', ['zzzzz-8i9sb-4cf0nhn6xte809j',
 172                                 'zzzzz-8i9sb-pshmckwoma9plh7']]]
 173     }
 174     assert_response :success
 175     found = assigns(:objects).collect(&:uuid)
 176     assert_equal found.sort, ['zzzzz-8i9sb-4cf0nhn6xte809j',
 177                               'zzzzz-8i9sb-pshmckwoma9plh7']
 178   end
 179
 180   test "search jobs by started_at with < query" do
 181     authorize_with :active
 182     get :index, {
 183       filters: [['started_at', '<', Time.now.to_s]]
 184     }
 185     assert_response :success
 186     found = assigns(:objects).collect(&:uuid)
 187     assert_equal true, !!found.index('zzzzz-8i9sb-pshmckwoma9plh7')
 188   end
 189
 190   test "search jobs by started_at with > query" do
 191     authorize_with :active
 192     get :index, {
 193       filters: [['started_at', '>', Time.now.to_s]]
 194     }
 195     assert_response :success
 196     assert_equal 0, assigns(:objects).count
 197   end
 198
 199   test "search jobs by started_at with >= query on metric date" do
 200     authorize_with :active
 201     get :index, {
 202       filters: [['started_at', '>=', '2014-01-01']]
 203     }
 204     assert_response :success
 205     found = assigns(:objects).collect(&:uuid)
 206     assert_equal true, !!found.index('zzzzz-8i9sb-pshmckwoma9plh7')
 207   end
 208
 209   test "search jobs by started_at with >= query on metric date and time" do
 210     authorize_with :active
 211     get :index, {
 212       filters: [['started_at', '>=', '2014-01-01 01:23:45']]
 213     }
 214     assert_response :success
 215     found = assigns(:objects).collect(&:uuid)
 216     assert_equal true, !!found.index('zzzzz-8i9sb-pshmckwoma9plh7')
 217   end
 218
 219   test "search jobs with 'any' operator" do
 220     authorize_with :active
 221     get :index, {
 222       where: { any: ['contains', 'pshmckw'] }
 223     }
 224     assert_response :success
 225     found = assigns(:objects).collect(&:uuid)
 226     assert_equal 0, found.index('zzzzz-8i9sb-pshmckwoma9plh7')
 227     assert_equal 1, found.count
 228   end
 229
 230   test "search jobs by nonexistent column with < query" do
 231     authorize_with :active
 232     get :index, {
 233       filters: [['is_borked', '<', 'fizzbuzz']]
 234     }
 235     assert_response 422
 236   end
 237
 238   test "finish a job" do
 239     authorize_with :active
 240     put :update, {
 241       id: jobs(:nearly_finished_job).uuid,
 242       job: {
 243         output: '551392cc37a317abf865b95f66f4ef94+101',
 244         log: '9215de2a951a721f5f156bc08cf63ad7+93',
 245         tasks_summary: {done: 1, running: 0, todo: 0, failed: 0},
 246         success: true,
 247         running: false,
 248         finished_at: Time.now.to_s
 249       }
 250     }
 251     assert_response :success
 252   end
 253
 254 end