Add UpdatableTimer example

Author: taonic

examples/bin/worker

@@ -70,6 +70,7 @@ worker.register_workflow(SlowChildWorkflow)
 worker.register_workflow(StartChildWorkflowWorkflow)
 worker.register_workflow(TimeoutWorkflow)
 worker.register_workflow(TripBookingWorkflow)
+worker.register_workflow(UpdatableTimer)
 worker.register_workflow(UpsertSearchAttributesWorkflow)
 worker.register_workflow(WaitForWorkflow)
 worker.register_workflow(WaitForExternalSignalWorkflow)

examples/spec/integration/updatable_timer_spec.rb

@@ -0,0 +1,22 @@
+require 'workflows/updatable_timer'
+
+describe UpdatableTimer, :integration do
+  let(:initial_duration) { 5 }
+  let(:final_duration) { 1.1 }
+
+  it 'updates timer duration via signal' do
+    workflow_id, run_id = run_workflow(UpdatableTimer, initial_duration)
+    Temporal.signal_workflow(UpdatableTimer, :update_timer, workflow_id, run_id, 3)
+    Temporal.signal_workflow(UpdatableTimer, :update_timer, workflow_id, run_id, final_duration)
+
+    e2e_duration = Temporal.await_workflow_result(
+      UpdatableTimer,
+      workflow_id: workflow_id,
+      run_id: run_id,
+    )
+
+    latency_tolerance = 0.2
+    expect(e2e_duration).to be > final_duration
+    expect(e2e_duration).to be < final_duration + latency_tolerance
+  end
+end

examples/workflows/updatable_timer.rb

@@ -0,0 +1,34 @@
+class UpdatableTimer < Temporal::Workflow
+  def execute(sleep_duration)
+    started_at = workflow.now
+    execute_in_timer(workflow, sleep_duration) do
+      workflow.logger.info('Executing workflow')
+      return workflow.now - started_at
+    end
+  end
+
+  def execute_in_timer(workflow, sleep_duration, &blk)
+    while sleep_duration > 0
+      signal_received = false
+      workflow.on_signal('update_timer') do |new_duration|
+        workflow.logger.info("Received update_timer signal with new duration: #{new_duration}")
+        sleep_duration = new_duration
+        signal_received = true
+      end
+
+      timer = workflow.start_timer(sleep_duration)
+      workflow.logger.info("Started timer with duration: #{sleep_duration}s")
+
+      workflow.wait_until do
+        timer.finished? || signal_received
+      end
+
+      if timer.finished?
+        workflow.logger.info("Timer fired")
+        break
+      end
+    end
+
+    yield
+  end
+end