Function runInActiveSpan

packages/query-plan-executor/src/tracing/tracer.ts:9–25

(
  nameOrOptions: string | ExtendedSpanOptions,
  fn: (span: Span) => Promise<R>,
)

export const tracer = trace.getTracer('query-plan-executor', version)

export function runInActiveSpan<R>(
  nameOrOptions: string | ExtendedSpanOptions,
  fn: (span: Span) => Promise<R>,
): Promise<R> {
  const options = normalizeSpanOptions(nameOrOptions)

  return tracer.startActiveSpan(options.name, options, async (span) => {
    try {
      return await fn(span)
    } catch (error) {
      span.recordException(extractErrorFromUnknown(error))
      throw error
    } finally {
      span.end()
    }
  })
}