Function _wrapped_session_async

agentops/sdk/decorators/factory.py:317–346

()

                elif is_async:

                    async def _wrapped_session_async() -> Any:
                        trace_context: Optional[TraceContext] = None
                        try:
                            trace_context = tracer.start_trace(trace_name=operation_name, tags=tags)
                            if not trace_context:
                                logger.error(
                                    f"Failed to start trace for @trace '{operation_name}'. Executing without trace."
                                )
                                return await wrapped_func(*args, **kwargs)
                            try:
                                _record_entity_input(trace_context.span, args, kwargs)
                            except Exception as e:
                                logger.warning(f"Input recording failed for @trace '{operation_name}': {e}")
                            result = await wrapped_func(*args, **kwargs)
                            try:
                                _record_entity_output(trace_context.span, result)
                            except Exception as e:
                                logger.warning(f"Output recording failed for @trace '{operation_name}': {e}")
                            tracer.end_trace(trace_context, "Success")
                            return result
                        except Exception:
                            if trace_context:
                                tracer.end_trace(trace_context, "Indeterminate")
                            raise
                        finally:
                            if trace_context and trace_context.span.is_recording():
                                logger.warning(
                                    f"Trace for @trace '{operation_name}' not explicitly ended. Ending as 'Unknown'."
                                )
                                tracer.end_trace(trace_context, "Unknown")

                    return _wrapped_session_async()
                else:  # Sync function for SpanKind.SESSION