Function traceBlockExecution

apps/sim/lib/core/telemetry.ts:394–434

(
  blockType: string,
  blockId: string,
  blockName: string,
  fn: (span: Span) => Promise<T>
)

 * Can be called from block handlers during execution for real-time tracing
 */
export async function traceBlockExecution<T>(
  blockType: string,
  blockId: string,
  blockName: string,
  fn: (span: Span) => Promise<T>
): Promise<T> {
  const tracer = getTracer()

  const blockMapping = BLOCK_TYPE_MAPPING[blockType] || {
    spanName: `block.${blockType}`,
    spanKind: 'internal',
    getAttributes: () => ({}),
  }

  return tracer.startActiveSpan(
    blockMapping.spanName,
    {
      attributes: {
        [TraceAttr.BlockType]: blockType,
        [TraceAttr.BlockId]: blockId,
        [TraceAttr.BlockName]: blockName,
      },
    },
    async (span) => {
      try {
        const result = await fn(span)
        span.setStatus({ code: SpanStatusCode.OK })
        return result
      } catch (error) {
        span.setStatus({
          code: SpanStatusCode.ERROR,
          message: getErrorMessage(error, 'Block execution failed'),
        })
        span.recordException(toError(error))
        throw error
      } finally {
        span.end()
      }
    }
  )
}

/**
 * Track platform events (workflow creation, knowledge base operations, etc.)