Class: Hatchet::Features::BulkCancelReplayOpts

Inherits:
Object
  • Object
show all
Defined in:
lib/hatchet/features/runs.rb

Overview

Options for bulk cancel and replay operations

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(ids: nil, filters: nil) ⇒ BulkCancelReplayOpts

Returns a new instance of BulkCancelReplayOpts.

Raises:

  • (ArgumentError) 


25
26
27
28
29
30
31
 
# File 'lib/hatchet/features/runs.rb', line 25

def initialize(ids: nil, filters: nil)
  raise ArgumentError, "ids or filters must be set" if !ids && !filters
  raise ArgumentError, "ids and filters cannot both be set" if ids && filters

  @ids = ids
  @filters = filters
end

Instance Attribute Details

#filters ⇒ Object

Returns the value of attribute filters.



23
24
25
 
# File 'lib/hatchet/features/runs.rb', line 23

def filters
  @filters
end

#ids ⇒ Object

Returns the value of attribute ids.



23
24
25
 
# File 'lib/hatchet/features/runs.rb', line 23

def ids
  @ids
end

Instance Method Details

#to_cancel_request ⇒ Object 



45
46
47
48
49
50
 
# File 'lib/hatchet/features/runs.rb', line 45

def to_cancel_request
  HatchetSdkRest::V1CancelTaskRequest.new(
    external_ids: @ids,
    filter: v1_task_filter,
  )
end

#to_replay_request ⇒ Object 



52
53
54
55
56
57
 
# File 'lib/hatchet/features/runs.rb', line 52

def to_replay_request
  HatchetSdkRest::V1ReplayTaskRequest.new(
    external_ids: @ids,
    filter: v1_task_filter,
  )
end

#v1_task_filter ⇒ Object 



33
34
35
36
37
38
39
40
41
42
43
 
# File 'lib/hatchet/features/runs.rb', line 33

def v1_task_filter
  return nil unless @filters

  HatchetSdkRest::V1TaskFilter.new(
    since: @filters.since&.utc&.iso8601,
    _until: @filters.until_time&.utc&.iso8601,
    statuses: @filters.statuses,
    workflow_ids: @filters.workflow_ids,
    additional_metadata: maybe_additional_metadata_to_kv(@filters.additional_metadata),
  )
end