Sha256: c0ffe2563d9494ef23ab6d359fb760914b317862c5a13cf1b2b4a94ced898756
Contents?: true
Size: 1.87 KB
Versions: 4
Compression:
Stored size: 1.87 KB
Contents
module Marty
module Promises
module Ruby
module Create
def self.call(module_name:, method_name:, method_args:, params: {})
default_timeout = Marty::Promise::DEFAULT_PROMISE_TIMEOUT
promise_params = params.with_indifferent_access
title = promise_params['p_title'] || "#{module_name}.#{method_name}"
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: 'ruby'
)
begin
promise_job = Marty::PromiseRubyJob.new(
promise,
title,
module_name,
method_name,
method_args,
hook
)
job = Delayed::Job.enqueue(promise_job, priority: priority)
rescue StandardError => e
res = { 'error' => e.message }
promise.set_start
promise.set_result(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, 'result')
end
end
end
end
end
Version data entries
4 entries across 4 versions & 1 rubygems