Class: Temporalio::Activity::Info

Inherits:

Data

• Object
• Data
• Temporalio::Activity::Info

Defined in:

lib/temporalio/activity/info.rb,
lib/temporalio/activity/info.rb

Overview

Note:

WARNING: This class may have required parameters added to its constructor. Users should not instantiate this class or it may break in incompatible ways.

Information about an activity.

Instance Attribute Summary

• #activity_id ⇒ String

  ID for the activity.

• #activity_type ⇒ String

  Type name for the activity.

• #attempt ⇒ Integer

  Attempt the activity is on.

• #current_attempt_scheduled_time ⇒ Time

  When the current attempt was scheduled.

• #heartbeat_timeout ⇒ Float^?

  Heartbeat timeout set by the caller.

• #local? ⇒ Boolean

  Whether the activity is a local activity or not.

• #priority ⇒ Priority

  The priority of this activity.

• #raw_heartbeat_details ⇒ Array<Converter::RawValue>

  Raw details from the last heartbeat of the last attempt.

• #retry_policy ⇒ RetryPolicy^?

  Retry policy for the activity.

• #schedule_to_close_timeout ⇒ Float^?

  Schedule to close timeout set by the caller.

• #scheduled_time ⇒ Time

  When the activity was scheduled.

• #start_to_close_timeout ⇒ Float^?

  Start to close timeout set by the caller.

• #started_time ⇒ Time

  When the activity started.

• #task_queue ⇒ String

  Task queue this activity is on.

• #task_token ⇒ String

  Task token uniquely identifying this activity.

• #workflow_id ⇒ String

  Workflow ID that started this activity.

• #workflow_namespace ⇒ String

  Namespace this activity is on.

• #workflow_run_id ⇒ String

  Workflow run ID that started this activity.

• #workflow_type ⇒ String

  Workflow type name that started this activity.

Instance Method Summary

• #heartbeat_details(hints: nil) ⇒ Array<Object>

  Convert raw heartbeat details into Ruby types.

Instance Attribute Details

#activity_id ⇒ String

# File 'lib/temporalio/activity/info.rb', line 77

def activity_id
  @activity_id
end

#activity_type ⇒ String

# File 'lib/temporalio/activity/info.rb', line 77

def activity_type
  @activity_type
end

#attempt ⇒ Integer

# File 'lib/temporalio/activity/info.rb', line 77

def attempt
  @attempt
end

#current_attempt_scheduled_time ⇒ Time

# File 'lib/temporalio/activity/info.rb', line 77

def current_attempt_scheduled_time
  @current_attempt_scheduled_time
end

#heartbeat_timeout ⇒ Float^?

# File 'lib/temporalio/activity/info.rb', line 77

def heartbeat_timeout
  @heartbeat_timeout
end

#local? ⇒ Boolean

# File 'lib/temporalio/activity/info.rb', line 77

def local?
  @local?
end

#priority ⇒ Priority

# File 'lib/temporalio/activity/info.rb', line 77

def priority
  @priority
end

#raw_heartbeat_details ⇒ Array<Converter::RawValue>

# File 'lib/temporalio/activity/info.rb', line 77

def raw_heartbeat_details
  @raw_heartbeat_details
end

#retry_policy ⇒ RetryPolicy^?

# File 'lib/temporalio/activity/info.rb', line 77

def retry_policy
  @retry_policy
end

#schedule_to_close_timeout ⇒ Float^?

# File 'lib/temporalio/activity/info.rb', line 77

def schedule_to_close_timeout
  @schedule_to_close_timeout
end

#scheduled_time ⇒ Time

# File 'lib/temporalio/activity/info.rb', line 77

def scheduled_time
  @scheduled_time
end

#start_to_close_timeout ⇒ Float^?

# File 'lib/temporalio/activity/info.rb', line 77

def start_to_close_timeout
  @start_to_close_timeout
end

#started_time ⇒ Time

# File 'lib/temporalio/activity/info.rb', line 77

def started_time
  @started_time
end

#task_queue ⇒ String

# File 'lib/temporalio/activity/info.rb', line 77

def task_queue
  @task_queue
end

#task_token ⇒ String

# File 'lib/temporalio/activity/info.rb', line 77

def task_token
  @task_token
end

#workflow_id ⇒ String

# File 'lib/temporalio/activity/info.rb', line 77

def workflow_id
  @workflow_id
end

#workflow_namespace ⇒ String

# File 'lib/temporalio/activity/info.rb', line 77

def workflow_namespace
  @workflow_namespace
end

#workflow_run_id ⇒ String

# File 'lib/temporalio/activity/info.rb', line 77

def workflow_run_id
  @workflow_run_id
end

#workflow_type ⇒ String

# File 'lib/temporalio/activity/info.rb', line 77

def workflow_type
  @workflow_type
end

Instance Method Details

#heartbeat_details(hints: nil) ⇒ Array<Object>

Convert raw heartbeat details into Ruby types.

Note, this live-converts every invocation.

# File 'lib/temporalio/activity/info.rb', line 84

def heartbeat_details(hints: nil)
  Internal::ProtoUtils.convert_from_payload_array(
    Context.current.payload_converter,
    raw_heartbeat_details.map(&:payload),
    hints:
  )
end