1093
rowTypeExecutionTaskID)
1094
} else if newBufferedEvents != nil {
1095
>
values := make(map[string]any)
util.go
1096
>
values["encoding_type"] = newBufferedEvents.EncodingType.String()
1097
>
values["version"] = int64(0)
1098
>
values["data"] = newBufferedEvents.Data
1099
>
newEventValues := []map[string]any{values}
1100
>
batch.Query(templateAppendBufferedEventsQuery,
1101
>
newEventValues,
1102
>
shardID,
1103
>
rowTypeExecution,
1104
>
namespaceID,
1105
>
workflowID,
1106
>
runID,
1107
>
defaultVisibilityTimestamp,
1108
>
rowTypeExecutionTaskID)
1109
>
}
1110
}
1111