ActivityStateReplicator should trigger history resend when mutable state is no found

dhiaayachi / temporal

Temporal service

https://docs.temporal.io

MIT License

0 stars 0 forks source link

ActivityStateReplicator should trigger history resend when mutable state is no found #131

Open dhiaayachi opened 2 weeks ago

dhiaayachi commented 2 weeks ago

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.

dhiaayachi commented 1 day ago

Thanks for reporting the issue. It is a known issue that we are currently investigating. We will try to fix this issue in the next release.

Here are some relevant documents:

- [Retry Policies](https://docs.temporal.io/encyclopedia/retry-policies) 
- [Activity Retry Simulator](https://docs.temporal.io/develop/activity-retry-simulator)