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

Run the following command to start worker

./bin/query -m worker

Run the following command to start trip workflow

./bin/recovery -m trigger -w UserA -wt main.TripWorkflow

Run the following command to query trip workflow

./bin/recovery -m query -w UserA

Run the following command to send signal to trip workflow

./bin/recovery -m signal -w UserA -s '{"ID": "Trip1", "Total": 10}'

Run the following command to start recovery workflow

./bin/recovery -m trigger -w UserB -wt recoveryworkflow -i '{"Type": "TripWorkflow", "Concurrency": 2}'

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

pFad - (p)hone/(F)rame/(a)nonymizer/(d)eclutterfier! Saves Data!