Module: Marty::Promises::Delorean::Create

Defined in:
app/services/marty/promises/delorean/create.rb

Class Method Summary collapse

Class Method Details

.call(params:, script:, node_name:, attr:, args:, tag:) ⇒ Object 



5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
 
# File 'app/services/marty/promises/delorean/create.rb', line 5

def self.call(params:, script:, node_name:, attr:, args:, tag:)
  default_timeout = Marty::Promise::DEFAULT_PROMISE_TIMEOUT

  promise_params = params.with_indifferent_access

  title = promise_params['p_title'] || "#{script}::#{node_name.demodulize}"
  timeout = promise_params['p_timeout'] || default_timeout
  hook = promise_params['p_hook']

  default_priority = 0
  pid = promise_params[:_parent_id]
  if pid
    ppr = Marty::Promise.find_by(id: pid)
    # make sure parent isn't cancelled
    return if ppr&.result&.[]('error') == 'Cancelled'

    default_priority = ppr.priority if ppr
  end
  priority = promise_params['p_priority'] || default_priority

  promise = Marty::Promise.create(
    title: title,
    user_id: promise_params[:_user_id],
    parent_id: promise_params[:_parent_id],
    priority: priority,
    promise_type: 'delorean',
    timeout: timeout
  )

  params[:_promise_id] = promise.id

  begin
    promise_job = Marty::PromiseJob.new(
      promise,
      title,
      script,
      tag,
      node_name,
      params,
      args,
      hook,
      # FIXME: should we use default timeout if not specified
      # Do we want to limit job execution time with that?
      promise_params['p_timeout']
    )

    job = Delayed::Job.enqueue(
      promise_job,
      priority: priority,
      queue: promise_params['p_queue'] ||
        Delayed::Worker.default_queue_name)
  rescue StandardError => e
    # log "CALLERR #{exc}"
    res = ::Delorean::Engine.grok_runtime_exception(e)
    promise.set_start
    promise.set_result(res)
    # log "CALLERRSET #{res}"
    raise
  end

  # keep a reference to the job. This is needed in case we want to
  # work off a promise job that we're waiting for and which hasn't
  # been reserved yet.
  promise.job_id = job.id
  promise.save!

  Marty::PromiseProxy.new(promise.id, timeout, attr)
end