Class: ActiveJob::Temporal::Activities::DependencyStatusActivity

Inherits:
Temporalio::Activity::Definition
  • Object
show all
Defined in:
lib/activejob/temporal/activities/dependency_status_activity.rb

Constant Summary collapse

SAFE_QUERY_VALUE_PATTERN = 
/\A[A-Za-z0-9_.:-]+\z/
WORKFLOW_STATES = 
{
  Temporalio::Client::WorkflowExecutionStatus::RUNNING => "running",
  Temporalio::Client::WorkflowExecutionStatus::COMPLETED => "completed",
  Temporalio::Client::WorkflowExecutionStatus::FAILED => "failed",
  Temporalio::Client::WorkflowExecutionStatus::CANCELED => "canceled",
  Temporalio::Client::WorkflowExecutionStatus::TERMINATED => "terminated",
  Temporalio::Client::WorkflowExecutionStatus::CONTINUED_AS_NEW => "continued_as_new",
  Temporalio::Client::WorkflowExecutionStatus::TIMED_OUT => "timed_out"
}.freeze

Instance Method Summary collapse

Instance Method Details

#execute(dependencies) ⇒ Object 



24
25
26
 
# File 'lib/activejob/temporal/activities/dependency_status_activity.rb', line 24

def execute(dependencies)
  Array(dependencies).map { |dependency| status_for(normalize_dependency(dependency)) }
end