Add dry-run mode for XDC system workflows

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: laniehei

common/dynamicconfig/constants.go

@@ -3094,6 +3094,11 @@ WorkerActivitiesPerSecond, MaxConcurrentActivityTaskPollers.
 		false,
 		`WorkerEnableHistoryRateLimiter decides whether to generate migration tasks with history length rate limiter.`,
 	)
+	WorkerDryRunMode = NewGlobalBoolSetting(
+		"worker.dryRunMode",
+		false,
+		`WorkerDryRunMode causes XDC system workflows (force-replication, namespace-handover) to complete immediately without doing real work. Use for testing.`,
+	)
 	MaxUserMetadataSummarySize = NewNamespaceIntSetting(
 		"limit.userMetadataSummarySize",
 		400,

service/worker/migration/activities.go

@@ -114,6 +114,7 @@ type (
 		namespaceReplicationQueue        persistence.NamespaceReplicationQueue
 		generateMigrationTaskViaFrontend dynamicconfig.BoolPropertyFn
 		enableHistoryRateLimiter         dynamicconfig.BoolPropertyFn
+		dryRunMode                       dynamicconfig.BoolPropertyFn
 		workflowVerifier                 WorkflowVerifier
 		chasmRegistry                    *chasm.Registry
 	}
@@ -152,6 +153,11 @@ func (r verifyResult) isVerified() bool {
 // changing all existing tooling around namespace migration to start workflows & activities on the new task queue.
 // Another approach is to use separate workers for workflow tasks and activities and keep existing tooling unchanged.
 
+// IsDryRunMode returns whether the cell is in dry-run mode.
+func (a *activities) IsDryRunMode(_ context.Context) (bool, error) {
+	return a.dryRunMode(), nil
+}
+
 // GetMetadata returns history shard count and namespaceID for requested namespace.
 func (a *activities) GetMetadata(_ context.Context, request metadataRequest) (*metadataResponse, error) {
 	nsEntry, err := a.namespaceRegistry.GetNamespace(namespace.Name(request.Namespace))

service/worker/migration/force_replication_workflow.go

@@ -134,6 +134,10 @@ func ForceReplicationWorkflow(ctx workflow.Context, params ForceReplicationParam
 		}, nil
 	})
 
+	if dryRun, _ := isDryRunMode(ctx); dryRun {
+		return nil
+	}
+
 	if err := validateAndSetForceReplicationParams(ctx, &params); err != nil {
 		return err
 	}
@@ -217,6 +221,10 @@ func ForceReplicationWorkflowV2(ctx workflow.Context, params ForceReplicationPar
 		}, nil
 	})
 
+	if dryRun, _ := isDryRunMode(ctx); dryRun {
+		return nil
+	}
+
 	if err := validateAndSetForceReplicationParams(ctx, &params); err != nil {
 		return err
 	}
@@ -337,6 +345,18 @@ func ForceTaskQueueUserDataReplicationWorkflow(ctx workflow.Context, params Task
 	return err
 }
 
+func isDryRunMode(ctx workflow.Context) (bool, error) {
+	lao := workflow.LocalActivityOptions{
+		StartToCloseTimeout: 5 * time.Second,
+	}
+	var a *activities
+	var dryRun bool
+	err := workflow.ExecuteLocalActivity(
+		workflow.WithLocalActivityOptions(ctx, lao), a.IsDryRunMode,
+	).Get(ctx, &dryRun)
+	return dryRun, err
+}
+
 func validateAndSetForceReplicationParams(ctx workflow.Context, params *ForceReplicationParams) error {
 	if len(params.Namespace) == 0 {
 		return temporal.NewNonRetryableApplicationError("InvalidArgument: Namespace is required", "InvalidArgument", nil)

service/worker/migration/fx.go

@@ -124,6 +124,7 @@ func (wc *replicationWorkerComponent) activities() *activities {
 		forceReplicationMetricsHandler:   wc.MetricsHandler.WithTags(metrics.WorkflowTypeTag(forceReplicationWorkflowName)),
 		generateMigrationTaskViaFrontend: dynamicconfig.WorkerGenerateMigrationTaskViaFrontend.Get(wc.DynamicCollection),
 		enableHistoryRateLimiter:         dynamicconfig.WorkerEnableHistoryRateLimiter.Get(wc.DynamicCollection),
+		dryRunMode:                       dynamicconfig.WorkerDryRunMode.Get(wc.DynamicCollection),
 		workflowVerifier:                 wc.WorkflowVerifier,
 		chasmRegistry:                    wc.ChasmRegistry,
 	}

service/worker/migration/handover_workflow.go

@@ -75,6 +75,11 @@ func NamespaceHandoverWorkflow(ctx workflow.Context, params NamespaceHandoverPar
 	if err := validateAndSetNamespaceHandoverParams(&params); err != nil {
 		return err
 	}
+
+	if dryRun, _ := isDryRunMode(ctx); dryRun {
+		return nil
+	}
+
 	retryPolicy := &temporal.RetryPolicy{
 		InitialInterval:    time.Second,
 		MaximumInterval:    time.Second,