(trx: Pick<typeof db, 'execute'>)
| 279 | } |
| 280 | |
| 281 | async function setExecutionLogWriteTimeouts(trx: Pick<typeof db, 'execute'>): Promise<void> { |
| 282 | await trx.execute( |
| 283 | sql.raw(`SET LOCAL statement_timeout = '${EXECUTION_LOG_STATEMENT_TIMEOUT_MS}ms'`) |
| 284 | ) |
| 285 | await trx.execute(sql.raw(`SET LOCAL lock_timeout = '${EXECUTION_LOG_LOCK_TIMEOUT_MS}ms'`)) |
| 286 | await trx.execute( |
| 287 | sql.raw(`SET LOCAL idle_in_transaction_session_timeout = '${EXECUTION_LOG_IDLE_TIMEOUT_MS}ms'`) |
| 288 | ) |
| 289 | } |
| 290 | |
| 291 | function countTraceSpans(traceSpans?: TraceSpan[]): number { |
| 292 | if (!Array.isArray(traceSpans) || traceSpans.length === 0) { |
no test coverage detected