Exception: Temporalio::Workflow::ContinueAsNewError

Inherits:
Error
  • Object
show all
Defined in:
lib/temporalio/workflow.rb

Overview

Error that is raised by a workflow out of the primary workflow method to issue a continue-as-new.

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods inherited from Error

canceled?

Constructor Details

#initialize(*args, workflow: nil, task_queue: nil, run_timeout: nil, task_timeout: nil, retry_policy: nil, memo: nil, search_attributes: nil, headers: {}) ⇒ ContinueAsNewError

Create a continue as new error.

Parameters:

  • args (Array<Object>) —

    Arguments for the new workflow.

  • workflow (Class<Workflow::Definition>, String, Symbol, nil) (defaults to: nil) —

    Workflow definition class or workflow name. If unset/nil, the current workflow is used.

  • task_queue (String, nil) (defaults to: nil) —

    Task queue for the workflow. If unset/nil, the current workflow task queue is used.

  • run_timeout (Float, nil) (defaults to: nil) —

    Timeout of a single workflow run in seconds. The default is not carried over from the current workflow.

  • task_timeout (Float, nil) (defaults to: nil) —

    Timeout of a single workflow task in seconds. The default is not carried over from the current workflow.

  • retry_policy (RetryPolicy, nil) (defaults to: nil) —

    Retry policy for the workflow. If unset/nil, the current workflow retry policy is used.

  • memo (Hash{String, Symbol => Object}, nil) (defaults to: nil) —

    Memo for the workflow. If unset/nil, the current workflow memo is used.

  • search_attributes (SearchAttributes, nil) (defaults to: nil) —

    Search attributes for the workflow. If unset/nil, the current workflow search attributes are used.

  • headers (Hash<String, Object>) (defaults to: {}) —

    Headers for the workflow. The default is not carried over from the current workflow.



493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
 
# File 'lib/temporalio/workflow.rb', line 493

def initialize(
  *args,
  workflow: nil,
  task_queue: nil,
  run_timeout: nil,
  task_timeout: nil,
  retry_policy: nil,
  memo: nil,
  search_attributes: nil,
  headers: {}
)
  super('Continue as new')
  @args = args
  @workflow = workflow
  @task_queue = task_queue
  @run_timeout = run_timeout
  @task_timeout = task_timeout
  @retry_policy = retry_policy
  @memo = memo
  @search_attributes = search_attributes
  @headers = headers
  Workflow._current.initialize_continue_as_new_error(self)
end

Instance Attribute Details

#args ⇒ Object

Returns the value of attribute args.



471
472
473
 
# File 'lib/temporalio/workflow.rb', line 471

def args
  @args
end

#headers ⇒ Object

Returns the value of attribute headers.



471
472
473
 
# File 'lib/temporalio/workflow.rb', line 471

def headers
  @headers
end

#memo ⇒ Object

Returns the value of attribute memo.



471
472
473
 
# File 'lib/temporalio/workflow.rb', line 471

def memo
  @memo
end

#retry_policy ⇒ Object

Returns the value of attribute retry_policy.



471
472
473
 
# File 'lib/temporalio/workflow.rb', line 471

def retry_policy
  @retry_policy
end

#run_timeout ⇒ Object

Returns the value of attribute run_timeout.



471
472
473
 
# File 'lib/temporalio/workflow.rb', line 471

def run_timeout
  @run_timeout
end

#search_attributes ⇒ Object

Returns the value of attribute search_attributes.



471
472
473
 
# File 'lib/temporalio/workflow.rb', line 471

def search_attributes
  @search_attributes
end

#task_queue ⇒ Object

Returns the value of attribute task_queue.



471
472
473
 
# File 'lib/temporalio/workflow.rb', line 471

def task_queue
  @task_queue
end

#task_timeout ⇒ Object

Returns the value of attribute task_timeout.



471
472
473
 
# File 'lib/temporalio/workflow.rb', line 471

def task_timeout
  @task_timeout
end

#workflow ⇒ Object

Returns the value of attribute workflow.



471
472
473
 
# File 'lib/temporalio/workflow.rb', line 471

def workflow
  @workflow
end