temporal
temporal copied to clipboard
ActivityStateReplicator should trigger history resend when mutable state is no found
Expected Behavior
- Sync activity replication task should create the workflow if not found in the target cluster.
Actual Behavior
- Sync activity replication task will be dropped. https://github.com/temporalio/temporal/blob/a29cc498bfb13771b41a2eeaeda41f4622ae0a8f/service/history/ndc/activity_state_replicator.go#L222
Solution
- Return a RetryReplication error instead off nil to trigger history resend. History resender can handler the case where the workflow no longer existing in the source cluster.