Class: Conductor::Http::Models::TaskDef

Inherits:
BaseModel
  • Object
show all
Defined in:
lib/conductor/http/models/task_def.rb

Overview

Task definition model for registering task types with Conductor

Constant Summary collapse

SWAGGER_TYPES = 
{
  name: 'String',
  description: 'String',
  retry_count: 'Integer',
  timeout_seconds: 'Integer',
  input_keys: 'Array<String>',
  output_keys: 'Array<String>',
  timeout_policy: 'String',
  retry_logic: 'String',
  retry_delay_seconds: 'Integer',
  response_timeout_seconds: 'Integer',
  concurrent_exec_limit: 'Integer',
  rate_limit_per_frequency: 'Integer',
  rate_limit_frequency_in_seconds: 'Integer',
  isolation_group_id: 'String',
  execution_name_space: 'String',
  owner_email: 'String',
  poll_timeout_seconds: 'Integer',
  backoff_scale_factor: 'Integer'
}.freeze
ATTRIBUTE_MAP = 
{
  name: :name,
  description: :description,
  retry_count: :retryCount,
  timeout_seconds: :timeoutSeconds,
  input_keys: :inputKeys,
  output_keys: :outputKeys,
  timeout_policy: :timeoutPolicy,
  retry_logic: :retryLogic,
  retry_delay_seconds: :retryDelaySeconds,
  response_timeout_seconds: :responseTimeoutSeconds,
  concurrent_exec_limit: :concurrentExecLimit,
  rate_limit_per_frequency: :rateLimitPerFrequency,
  rate_limit_frequency_in_seconds: :rateLimitFrequencyInSeconds,
  isolation_group_id: :isolationGroupId,
  execution_name_space: :executionNameSpace,
  owner_email: :ownerEmail,
  poll_timeout_seconds: :pollTimeoutSeconds,
  backoff_scale_factor: :backoffScaleFactor
}.freeze

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods inherited from BaseModel

attribute_map, deserialize_model, deserialize_value, find_model_class, from_hash, from_json, parse_datetime, swagger_types, #to_h, #to_json

Constructor Details

#initialize(params = {}) ⇒ TaskDef

Returns a new instance of TaskDef.



72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
 
# File 'lib/conductor/http/models/task_def.rb', line 72

def initialize(params = {})
  @name = params[:name]
  @description = params[:description]
  @retry_count = params[:retry_count] || 3
  @timeout_seconds = params[:timeout_seconds] || 3600
  @input_keys = params[:input_keys] || []
  @output_keys = params[:output_keys] || []
  @timeout_policy = params[:timeout_policy] || TaskTimeoutPolicy::TIME_OUT_WF
  @retry_logic = params[:retry_logic] || RetryLogic::FIXED
  @retry_delay_seconds = params[:retry_delay_seconds] || 60
  @response_timeout_seconds = params[:response_timeout_seconds] || 600
  @concurrent_exec_limit = params[:concurrent_exec_limit]
  @rate_limit_per_frequency = params[:rate_limit_per_frequency]
  @rate_limit_frequency_in_seconds = params[:rate_limit_frequency_in_seconds]
  @isolation_group_id = params[:isolation_group_id]
  @execution_name_space = params[:execution_name_space]
  @owner_email = params[:owner_email]
  @poll_timeout_seconds = params[:poll_timeout_seconds]
  @backoff_scale_factor = params[:backoff_scale_factor] || 1
end

Instance Attribute Details

#backoff_scale_factor ⇒ Object

Returns the value of attribute backoff_scale_factor.



64
65
66
 
# File 'lib/conductor/http/models/task_def.rb', line 64

def backoff_scale_factor
  @backoff_scale_factor
end

#concurrent_exec_limit ⇒ Object

Returns the value of attribute concurrent_exec_limit.



64
65
66
 
# File 'lib/conductor/http/models/task_def.rb', line 64

def concurrent_exec_limit
  @concurrent_exec_limit
end

#description ⇒ Object

Returns the value of attribute description.



64
65
66
 
# File 'lib/conductor/http/models/task_def.rb', line 64

def description
  @description
end

#execution_name_space ⇒ Object

Returns the value of attribute execution_name_space.



64
65
66
 
# File 'lib/conductor/http/models/task_def.rb', line 64

def execution_name_space
  @execution_name_space
end

#input_keys ⇒ Object

Returns the value of attribute input_keys.



64
65
66
 
# File 'lib/conductor/http/models/task_def.rb', line 64

def input_keys
  @input_keys
end

#isolation_group_id ⇒ Object

Returns the value of attribute isolation_group_id.



64
65
66
 
# File 'lib/conductor/http/models/task_def.rb', line 64

def isolation_group_id
  @isolation_group_id
end

#name ⇒ Object

Returns the value of attribute name.



64
65
66
 
# File 'lib/conductor/http/models/task_def.rb', line 64

def name
  @name
end

#output_keys ⇒ Object

Returns the value of attribute output_keys.



64
65
66
 
# File 'lib/conductor/http/models/task_def.rb', line 64

def output_keys
  @output_keys
end

#owner_email ⇒ Object

Returns the value of attribute owner_email.



64
65
66
 
# File 'lib/conductor/http/models/task_def.rb', line 64

def owner_email
  @owner_email
end

#poll_timeout_seconds ⇒ Object

Returns the value of attribute poll_timeout_seconds.



64
65
66
 
# File 'lib/conductor/http/models/task_def.rb', line 64

def poll_timeout_seconds
  @poll_timeout_seconds
end

#rate_limit_frequency_in_seconds ⇒ Object

Returns the value of attribute rate_limit_frequency_in_seconds.



64
65
66
 
# File 'lib/conductor/http/models/task_def.rb', line 64

def rate_limit_frequency_in_seconds
  @rate_limit_frequency_in_seconds
end

#rate_limit_per_frequency ⇒ Object

Returns the value of attribute rate_limit_per_frequency.



64
65
66
 
# File 'lib/conductor/http/models/task_def.rb', line 64

def rate_limit_per_frequency
  @rate_limit_per_frequency
end

#response_timeout_seconds ⇒ Object

Returns the value of attribute response_timeout_seconds.



64
65
66
 
# File 'lib/conductor/http/models/task_def.rb', line 64

def response_timeout_seconds
  @response_timeout_seconds
end

#retry_count ⇒ Object

Returns the value of attribute retry_count.



64
65
66
 
# File 'lib/conductor/http/models/task_def.rb', line 64

def retry_count
  @retry_count
end

#retry_delay_seconds ⇒ Object

Returns the value of attribute retry_delay_seconds.



64
65
66
 
# File 'lib/conductor/http/models/task_def.rb', line 64

def retry_delay_seconds
  @retry_delay_seconds
end

#retry_logic ⇒ Object

Returns the value of attribute retry_logic.



64
65
66
 
# File 'lib/conductor/http/models/task_def.rb', line 64

def retry_logic
  @retry_logic
end

#timeout_policy ⇒ Object

Returns the value of attribute timeout_policy.



64
65
66
 
# File 'lib/conductor/http/models/task_def.rb', line 64

def timeout_policy
  @timeout_policy
end

#timeout_seconds ⇒ Object

Returns the value of attribute timeout_seconds.



64
65
66
 
# File 'lib/conductor/http/models/task_def.rb', line 64

def timeout_seconds
  @timeout_seconds
end