Module: ActiveJob::Temporal::Schedulable::ClassMethods

Defined in:
lib/activejob/temporal/schedulable.rb

Instance Method Summary collapse

Instance Method Details

#create_temporal_schedule(options = nil, **kwargs) ⇒ Object

Raises:

  • (ArgumentError) 


20
21
22
23
24
25
26
27
28
29
 
# File 'lib/activejob/temporal/schedulable.rb', line 20

def create_temporal_schedule(options = nil, **kwargs)
  if options || kwargs.any?
    schedule_options = merged_schedule_options(normalize_schedule_options(options, kwargs))
    return ActiveJob::Temporal::Schedule.new(self, schedule_options).create
  end

  raise ArgumentError, "No temporal_schedule defined for #{name}" unless temporal_schedule

  temporal_schedule.create
end

#temporal_schedule(options = nil, **kwargs) ⇒ Object 



13
14
15
16
17
18
 
# File 'lib/activejob/temporal/schedulable.rb', line 13

def temporal_schedule(options = nil, **kwargs)
  return @temporal_schedule if options.nil? && kwargs.empty?

  schedule_options = normalize_schedule_options(options, kwargs)
  @temporal_schedule = ActiveJob::Temporal::Schedule.new(self, schedule_options)
end

#temporal_schedule_handle(id: nil, client: ActiveJob::Temporal.client) ⇒ Object 



31
32
33
 
# File 'lib/activejob/temporal/schedulable.rb', line 31

def temporal_schedule_handle(id: nil, client: ActiveJob::Temporal.client)
  client.schedule_handle(id || temporal_schedule&.id || "ajsch:#{name}")
end