Class: Temporalio::Activity::Definition::Info
- Inherits:
-
Object
- Object
- Temporalio::Activity::Definition::Info
- Defined in:
- lib/temporalio/activity/definition.rb
Overview
Definition info of an activity. Activities are usually classes/instances that extend Temporalio::Activity::Definition, but definitions can also be manually created with a block via #initialize here.
Instance Attribute Summary collapse
-
#arg_hints ⇒ Array<Object>?
readonly
Argument hints.
-
#cancel_raise ⇒ Boolean
readonly
Whether to raise in thread/fiber on cancellation.
-
#executor ⇒ Symbol
readonly
Name of the executor.
-
#instance ⇒ Object, ...
readonly
The pre-created instance or the proc to create/return it.
-
#name ⇒ String, ...
readonly
Name of the activity, or nil if the activity is dynamic.
-
#proc ⇒ Proc
readonly
Proc for the activity.
-
#raw_args ⇒ Boolean
readonly
Whether to use Converters::RawValues as arguments.
-
#result_hint ⇒ Object?
readonly
Result hint.
Class Method Summary collapse
-
.from_activity(activity) ⇒ Object
Obtain definition info representing the given activity, which can be a class, instance, or definition info.
Instance Method Summary collapse
-
#initialize(name:, instance: nil, executor: :default, cancel_raise: true, raw_args: false, arg_hints: nil, result_hint: nil) { ... } ⇒ Info
constructor
Manually create activity definition info.
Constructor Details
#initialize(name:, instance: nil, executor: :default, cancel_raise: true, raw_args: false, arg_hints: nil, result_hint: nil) { ... } ⇒ Info
Manually create activity definition info. Most users will use an instance/class of Temporalio::Activity::Definition.
205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 |
# File 'lib/temporalio/activity/definition.rb', line 205 def initialize( name:, instance: nil, executor: :default, cancel_raise: true, raw_args: false, arg_hints: nil, result_hint: nil, &block ) @name = name @instance = instance raise ArgumentError, 'Must give block' unless block_given? @proc = block @executor = executor @cancel_raise = cancel_raise @raw_args = raw_args @arg_hints = arg_hints @result_hint = result_hint Internal::ProtoUtils.assert_non_reserved_name(name) end |
Instance Attribute Details
#arg_hints ⇒ Array<Object>? (readonly)
Returns Argument hints.
148 149 150 |
# File 'lib/temporalio/activity/definition.rb', line 148 def arg_hints @arg_hints end |
#cancel_raise ⇒ Boolean (readonly)
Returns Whether to raise in thread/fiber on cancellation. Default is ‘true`.
142 143 144 |
# File 'lib/temporalio/activity/definition.rb', line 142 def cancel_raise @cancel_raise end |
#executor ⇒ Symbol (readonly)
Returns Name of the executor. Default is ‘:default`.
139 140 141 |
# File 'lib/temporalio/activity/definition.rb', line 139 def executor @executor end |
#instance ⇒ Object, ... (readonly)
Returns The pre-created instance or the proc to create/return it.
133 134 135 |
# File 'lib/temporalio/activity/definition.rb', line 133 def instance @instance end |
#name ⇒ String, ... (readonly)
Returns Name of the activity, or nil if the activity is dynamic.
130 131 132 |
# File 'lib/temporalio/activity/definition.rb', line 130 def name @name end |
#proc ⇒ Proc (readonly)
Returns Proc for the activity. Should use Context#instance to access the instance.
136 137 138 |
# File 'lib/temporalio/activity/definition.rb', line 136 def proc @proc end |
#raw_args ⇒ Boolean (readonly)
Returns Whether to use Converters::RawValues as arguments.
145 146 147 |
# File 'lib/temporalio/activity/definition.rb', line 145 def raw_args @raw_args end |
#result_hint ⇒ Object? (readonly)
Returns Result hint.
151 152 153 |
# File 'lib/temporalio/activity/definition.rb', line 151 def result_hint @result_hint end |
Class Method Details
.from_activity(activity) ⇒ Object
Obtain definition info representing the given activity, which can be a class, instance, or definition info.
157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 |
# File 'lib/temporalio/activity/definition.rb', line 157 def self.from_activity(activity) # Class means create each time, instance means just call, definition # does nothing special case activity when Class unless activity < Definition raise ArgumentError, "Class '#{activity}' does not extend Temporalio::Activity::Definition" end details = activity._activity_definition_details new( name: details[:activity_name], instance: proc { activity.new }, executor: details[:activity_executor], cancel_raise: details[:activity_cancel_raise], raw_args: details[:activity_raw_args], arg_hints: details[:activity_arg_hints], result_hint: details[:activity_result_hint] ) { |*args| Context.current.instance&.execute(*args) } when Definition details = activity.class._activity_definition_details new( name: details[:activity_name], instance: activity, executor: details[:activity_executor], cancel_raise: details[:activity_cancel_raise], raw_args: details[:activity_raw_args], arg_hints: details[:activity_arg_hints], result_hint: details[:activity_result_hint] ) { |*args| Context.current.instance&.execute(*args) } when Info activity else raise ArgumentError, "#{activity} is not an activity class, instance, or definition info" end end |