if len(activityInfos) > 0 {
for scheduledEventId, blob := range activityInfos {
rows = append(rows, sqlplugin.ActivityInfoMapsRow{
ShardID: shardID,
NamespaceID: namespaceID,
WorkflowID: workflowID,
RunID: runID,
ScheduleID: scheduledEventId,
Data: blob.Data,
DataEncoding: blob.EncodingType.String(),
})
}
return serviceerror.NewUnavailablef("Failed to update activity info. Failed to execute update query. Error: %v", err)
}