1470
routingConfig *deploymentpb.RoutingConfig,
1471
versionData *deploymentspb.WorkerDeploymentVersionData,
1473
>
state := d.GetVersionState()
1474
>
activityCtx := workflow.WithActivityOptions(ctx, propagationActivityOptions)
1475
>
var syncRes deploymentspb.SyncDeploymentVersionUserDataResponse
1476
>
1477
>
err := workflow.ExecuteActivity(activityCtx, d.a.SyncDeploymentVersionUserData, &deploymentspb.SyncDeploymentVersionUserDataRequest{
1478
>
Version: state.GetVersion(),
1479
>
UpdateRoutingConfig: routingConfig,
1480
>
UpsertVersionData: versionData,
1481
>
Sync: batch,
1482
>
}).Get(ctx, &syncRes)
1483
>
1484
>
if err != nil {
1485
d.logger.Error("async propagation batch failed", "error", err)
1486
// Return empty map on error