Method: Funktor::WorkQueueHandler#delete_job_from_dynamodb

Defined in:
lib/funktor/work_queue_handler.rb

#delete_job_from_dynamodb(job) ⇒ Object 



102
103
104
105
106
107
108
109
110
111
112
113
 
# File 'lib/funktor/work_queue_handler.rb', line 102

def delete_job_from_dynamodb(job)
  puts "starting delete_job_from_dynamodb"
  dynamodb_client.delete_item({
    key: {
      "jobShard" => job.shard,
      "jobId" => job.job_id
    },
    table_name: delayed_job_table,
    return_values: "ALL_OLD"
  })
  puts "ending delete_job_from_dynamodb"
end