({
relabel,
dataset,
logger,
}: {
relabel: Relabel
dataset?: string
logger: Logger
})
| 236 | } |
| 237 | |
| 238 | export async function insertRelabel({ |
| 239 | relabel, |
| 240 | dataset, |
| 241 | logger, |
| 242 | }: { |
| 243 | relabel: Relabel |
| 244 | dataset?: string |
| 245 | logger: Logger |
| 246 | }) { |
| 247 | const resolvedDataset = dataset ?? DATASET |
| 248 | try { |
| 249 | // Stringify payload if needed |
| 250 | const relabelToInsert = { |
| 251 | ...relabel, |
| 252 | payload: |
| 253 | relabel.payload && typeof relabel.payload !== 'string' |
| 254 | ? JSON.stringify(relabel.payload) |
| 255 | : relabel.payload, |
| 256 | } |
| 257 | |
| 258 | await getClient() |
| 259 | .dataset(resolvedDataset) |
| 260 | .table(RELABELS_TABLE) |
| 261 | .insert(relabelToInsert) |
| 262 | |
| 263 | logger.debug({ relabelId: relabel.id }, 'Inserted relabel into BigQuery') |
| 264 | return true |
| 265 | } catch (error) { |
| 266 | logger.error( |
| 267 | { error, relabelId: relabel.id }, |
| 268 | 'Failed to insert relabel into BigQuery', |
| 269 | ) |
| 270 | return false |
| 271 | } |
| 272 | } |
| 273 | |
| 274 | export async function getRecentTraces( |
| 275 | limit: number = 10, |
no test coverage detected