Class: Aidp::Temporal::Activities::BaseActivity

Inherits:

Temporalio::Activity::Definition

• Object
• Temporalio::Activity::Definition
• Aidp::Temporal::Activities::BaseActivity

Defined in:

lib/aidp/temporal/activities/base_activity.rb

Overview

Base class for AIDP Temporal activities Provides common patterns and utilities for activity implementations

Direct Known Subclasses

AnalyzeIssueActivity, AnalyzeSubTaskActivity, CreatePlanActivity, CreatePrActivity, CreatePromptActivity, DiagnoseFailureActivity, PrepareNextIterationActivity, RecordCheckpointActivity, RunAgentActivity, RunTestsActivity, RunWorkLoopIterationActivity

Instance Method Summary

• #activity_context ⇒ Object

  Activity context (set by Temporal).

• #cancellation_requested? ⇒ Boolean

  Check if cancellation was requested.

• #check_cancellation! ⇒ Object

  Raise if cancellation was requested.

• #heartbeat(*details) ⇒ Object

  Send heartbeat to indicate activity is still running.

Instance Method Details

#activity_context ⇒ Object

Activity context (set by Temporal)

# File 'lib/aidp/temporal/activities/base_activity.rb', line 12

def activity_context
  Temporalio::Activity.context
end

#cancellation_requested? ⇒ Boolean

Check if cancellation was requested

Returns:

• (Boolean)

# File 'lib/aidp/temporal/activities/base_activity.rb', line 22

def cancellation_requested?
  Temporalio::Activity.cancellation_requested?
end

#check_cancellation! ⇒ Object

Raise if cancellation was requested

Raises:

• (Temporalio::Error::CanceledError)

# File 'lib/aidp/temporal/activities/base_activity.rb', line 27

def check_cancellation!
  raise Temporalio::Error::CanceledError, "Activity canceled" if cancellation_requested?
end

#heartbeat(*details) ⇒ Object

Send heartbeat to indicate activity is still running

# File 'lib/aidp/temporal/activities/base_activity.rb', line 17

def heartbeat(*details)
  Temporalio::Activity.heartbeat(*details)
end