838
}
839
840
>
timerTasksRows := make([]sqlplugin.TimerTasksRow, 0, len(timerTasks))
execution_util.go
841
>
for _, task := range timerTasks {
842
>
timerTasksRows = append(timerTasksRows, sqlplugin.TimerTasksRow{
843
>
ShardID: shardID,
844
>
VisibilityTimestamp: task.Key.FireTime,
845
>
TaskID: task.Key.TaskID,
846
>
Data: task.Blob.Data,
847
>
DataEncoding: task.Blob.EncodingType.String(),
848
>
})
849
>
}
850
852
>
if err != nil {
853
return serviceerror.NewUnavailablef("createTimerTasks failed. Error: %v", err)
854
}
856
>
if err != nil {
857
return serviceerror.NewUnavailablef("createTimerTasks failed. Could not verify number of rows inserted. Error: %v", err)
858
}
859
861
return serviceerror.NewUnavailablef("createTimerTasks failed. Inserted %v instead of %v rows into timer_tasks. Error: %v", rowsAffected, len(timerTasks), err)
862
}
864
}
865