Skip to content

Latest commit

 

History

History
26 lines (25 loc) · 925 Bytes

README.md

File metadata and controls

26 lines (25 loc) · 925 Bytes

Recovery Sample

This sample implements a RecoveryWorkflow which is designed to restart all TripWorkflow executions which are currently outstanding and replay all signals from previous run. This is useful where a bad code change is rolled out which causes workflows to get stuck or state is corrupted.

Steps to run this sample

  1. Run the following command to start worker
./bin/query -m worker
  1. Run the following command to start trip workflow
./bin/recovery -m trigger -w UserA -wt main.TripWorkflow
  1. Run the following command to query trip workflow
./bin/recovery -m query -w UserA
  1. Run the following command to send signal to trip workflow
./bin/recovery -m signal -w UserA -s '{"ID": "Trip1", "Total": 10}'
  1. Run the following command to start recovery workflow
./bin/recovery -m trigger -w UserB -wt recoveryworkflow -i '{"Type": "TripWorkflow", "Concurrency": 2}'