~tjcddlmZddlmZmZddlmZddlmZddlZddl m Z m Z m Z ddl mZmZmZmZmZmZmZdd lmZmZmZdd lmZdd lmZmZdd lmZm Z m!Z!m"Z"dd l#m$Z$m%Z%m&Z&m'Z'ddl(m)Z)m*Z*ddl+m,Z,ddl-m.Z.ddl/m0Z0ddgZ1GddeZ2GddeZ3GddZ4GddZ5GddZ6GddZ7dS)) annotations)ListUnion)datetime)LiteralN)thread_query_paramsthread_stats_paramsthread_list_traces_params)BodyOmitQueryHeadersNotGivenomit not_given) path_templatemaybe_transformasync_maybe_transform)cached_property)SyncAPIResourceAsyncAPIResource)to_raw_response_wrapperto_streamed_response_wrapperasync_to_raw_response_wrapper"async_to_streamed_response_wrapper)SyncItemsCursorGetPaginationAsyncItemsCursorGetPaginationSyncItemsCursorPostPaginationAsyncItemsCursorPostPagination)AsyncPaginatormake_request_options)Thread) ThreadStats) ThreadTraceThreadsResourceAsyncThreadsResourcec eZdZed'dZed(dZeeeedddedd)dZeeeeeeddded d*d!Z eddded"d+d&Z dS),r&returnThreadsResourceWithRawResponsec t|Sz This property can be used as a prefix for any HTTP method call to return the raw response object instead of the parsed content. )r*selfs i/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/langsmith/_openapi_client/resources/threads.pywith_raw_responsez!ThreadsResource.with_raw_response%s .d333$ThreadsResourceWithStreamingResponsec t|Sze An alternative to `.with_raw_response` that doesn't eagerly read the response body. )r2r-s r/with_streaming_responsez'ThreadsResource.with_streaming_response-s 4D999r1Ncursorfilter page_sizeselects extra_headers extra_query extra_bodytimeout thread_idstr project_idr7 str | Omitr8r9 int | Omitr:List[Literal['THREAD_ID', 'TRACE_ID', 'OP', 'PROMPT_TOKENS', 'COMPLETION_TOKENS', 'TOTAL_TOKENS', 'START_TIME', 'END_TIME', 'LATENCY', 'FIRST_TOKEN_TIME', 'INPUTS_PREVIEW', 'OUTPUTS_PREVIEW', 'INPUTS', 'OUTPUTS', 'ERROR', 'PROMPT_COST', 'COMPLETION_COST', 'TOTAL_COST', 'PROMPT_TOKEN_DETAILS', 'COMPLETION_TOKEN_DETAILS', 'PROMPT_COST_DETAILS', 'COMPLETION_COST_DETAILS', 'NAME', 'ERROR_PREVIEW']] | Omitr;Headers | Noner< Query | Noner= Body | Noner>'float | httpx.Timeout | None | NotGiven)SyncItemsCursorGetPagination[ThreadTrace]c |std||td|ttt ||| | t |||||dtjtSa Retrieve all traces belonging to a specific thread within a project. Self-hosted deployments require LangSmith `v0.16` or later. Args: project_id: `project_id` is the tracing project UUID (required). cursor: `cursor` is the opaque string from a previous response's `next_cursor`. Omit on the first request; pass the returned cursor to fetch the next page. filter: `filter` narrows which traces are returned for this thread, using a LangSmith filter expression evaluated against each root trace run. For example: eq(status, "success") or has(tags, "production"). See https://docs.langchain.com/langsmith/trace-query-syntax#filter-query-language for syntax. page_size: `page_size` is the maximum number of traces to return in this response. Defaults to 20 when omitted; must be between 1 and 100 inclusive when set. selects: `selects` lists which properties to include on each returned trace (repeatable query parameter). Accepts any value of the `ThreadTraceSelectField` enum. Properties not listed are omitted from each trace object; `trace_id` is always returned. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds 8Expected a non-empty value for `thread_id` but received z"/api/v2/threads/{thread_id}/tracesr?)rAr7r8r9r:r;r<r=r>query)pageoptionsmodel) ValueError _get_api_listrrr%r"rr ThreadListTracesParams r.r?rAr7r8r9r:r;r<r=r>s r/ list_traceszThreadsResource.list_traces4sZ geXaeeff f!! >) T T T-k:(+'%%&0"("(%.#* .D    '"   r1 r7r8max_start_timemin_start_timer9rAr;r<r=r>rYUnion[str, datetime] | OmitrZ%SyncItemsCursorPostPagination[Thread]c |dttt||||||dtjt ||| | tdSaQuery threads within a project (session), with cursor-based pagination. Returns threads matching the given time range and optional filter. Self-hosted deployments require LangSmith `v0.16` or later. Args: cursor: `cursor` is the opaque string from a previous response's `next_cursor`. Omit on the first request; pass the returned cursor to fetch the next page. filter: `filter` narrows which threads are returned, using a LangSmith filter expression evaluated against each thread's root run. For example: has(tags, "production") or eq(status, "error"). See https://docs.langchain.com/langsmith/trace-query-syntax#filter-query-language for syntax. max_start_time: `max_start_time` is the exclusive upper bound on thread activity (RFC3339 date-time). Defaults to now (UTC) when omitted. min_start_time: `min_start_time` is the inclusive lower bound on thread activity (RFC3339 date-time). Defaults to 1 day before now (UTC) when omitted. page_size: `page_size` is the maximum number of threads to return in this response. Defaults to 20 when omitted; must be between 1 and 100 inclusive when set. The response may contain fewer threads than `page_size` even when `next_cursor` is non-null. project_id: `project_id` is the tracing project UUID. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds z/api/v2/threads/query)r7r8rYrZr9rA)r;r<r=r>post)rPbodyrQrRmethod)rTrr#rr ThreadQueryParamsr" r.r7r8rYrZr9rAr;r<r=r>s r/rOzThreadsResource.querysl!! #.v6 $$&4&4!*", $5  )+Q[el%"   r1r8r;r<r=r>JList[Literal['TURNS', 'FIRST_START_TIME', 'LAST_START_TIME', 'LAST_END_TIME', 'LATENCY_P50', 'LATENCY_P99', 'PROMPT_TOKENS', 'PROMPT_COST', 'COMPLETION_TOKENS', 'COMPLETION_COST', 'TOTAL_TOKENS', 'TOTAL_COST', 'PROMPT_TOKEN_DETAILS', 'COMPLETION_TOKEN_DETAILS', 'PROMPT_COST_DETAILS', 'COMPLETION_COST_DETAILS', 'FEEDBACK_STATS']] session_idr$c|std||td|t||||t |||dt jtS) Compute aggregate stats for a single thread (turn count, latency percentiles, token/cost sums, and detail breakdowns) within a project. Self-hosted deployments require LangSmith `v0.16` or later. Args: selects: `selects` lists which aggregate stats to compute and return (repeatable query parameter). At least one value is required. Accepts any value of `SingleThreadStatsSelectField`. session_id: `session_id` is the tracing project (session) UUID (required). filter: `filter` narrows which of the thread's traces are aggregated, using a LangSmith filter expression. For example: lt(start_time, "2025-01-01T00:00:00Z") or eq(trace_id, "0190a1b2-c3d4-7ef0-a5b6-6ea3a82e9328"). See https://docs.langchain.com/langsmith/trace-query-syntax#filter-query-language for syntax. extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds rL!/api/v2/threads/{thread_id}/statsrMr:rfr8rNrQcast_to)rS_getrr"rr ThreadStatsParamsr$ r.r?r:rfr8r;r<r=r>s r/statszThreadsResource.statssz geXaeeff fyy = S S S(+'%%#*&0"( (9     !   r1)r)r*)r)r2)r?r@rAr@r7rBr8rBr9rCr:rDr;rEr<rFr=rGr>rHr)rI)r7rBr8rBrYr[rZr[r9rCrArBr;rEr<rFr=rGr>rHr)r\r?r@r:rerfr@r8rBr;rEr<rFr=rGr>rHr)r$ __name__ __module__ __qualname__rr0r5rrrWrOrpr1r/r&r&$s444_4:::_:"! $:)-$("&;DUc c c c c c P"!6:6: $!%)-$("&;DI I I I I I J")-$("&;DAP P P P P P P P r1c eZdZed'dZed(dZeeeedddedd)dZeeeeeeddded d*d!Z eddded"d+d&Z dS),r'r)#AsyncThreadsResourceWithRawResponsec t|Sr,)rxr-s r/r0z&AsyncThreadsResource.with_raw_response8s 34888r1)AsyncThreadsResourceWithStreamingResponsec t|Sr4)rzr-s r/r5z,AsyncThreadsResource.with_streaming_response@s 9>>>r1Nr6r?r@rAr7rBr8r9rCr:rDr;rEr<rFr=rGr>rHGAsyncPaginator[ThreadTrace, AsyncItemsCursorGetPagination[ThreadTrace]]c |std||td|ttt ||| | t |||||dtjtSrK) rSrTrrr%r"rr rUrVs r/rWz AsyncThreadsResource.list_tracesGsZ geXaeeff f!! >) T T T.{;(+'%%&0"("(%.#* .D    '"   r1rXrYr[rZ>AsyncPaginator[Thread, AsyncItemsCursorPostPagination[Thread]]c |dttt||||||dtjt ||| | tdSr^)rTr r#rr rbr"rcs r/rOzAsyncThreadsResource.querysl!! #/7 $$&4&4!*", $5  )+Q[el%"   r1rdrerfr$cK|std||td|t||||t |||dt jd{Vtd{VS)rhrLrirMrjNrNrk)rSrmrr"rr rnr$ros r/rpzAsyncThreadsResource.statssz geXaeeff fYY = S S S(+'%1#*&0"( (9     !         r1)r)rx)r)rz)r?r@rAr@r7rBr8rBr9rCr:rDr;rEr<rFr=rGr>rHr)r|)r7rBr8rBrYr[rZr[r9rCrArBr;rEr<rFr=rGr>rHr)r~rqrrrvr1r/r'r'7s999_9???_?"! $:)-$("&;DUc c c c c c P"!6:6: $!%)-$("&;DI I I I I I J")-$("&;DAP P P P P P P P r1ceZdZddZdS)r*threadsr&r)Nonec||_t|j|_t|j|_t|j|_dSN)_threadsrrWrOrpr.rs r/__init__z'ThreadsResourceWithRawResponse.__init__KsU 2    - M   - M   r1Nrr&r)rrsrtrurrvr1r/r*r*J(       r1r*ceZdZddZdS)rxrr'r)rc||_t|j|_t|j|_t|j|_dSr)rrrWrOrprs r/rz,AsyncThreadsResourceWithRawResponse.__init__ZsU 8    3 M   3 M   r1Nrr'r)rrrvr1r/rxrxYrr1rxceZdZddZdS)r2rr&r)rc||_t|j|_t|j|_t|j|_dSr)rrrWrOrprs r/rz-ThreadsResourceWithStreamingResponse.__init__isU 7    2 M   2 M   r1Nrrrvr1r/r2r2hrr1r2ceZdZddZdS)rzrr'r)rc||_t|j|_t|j|_t|j|_dSr)rrrWrOrprs r/rz2AsyncThreadsResourceWithStreamingResponse.__init__xsU =    8 M   8 M   r1Nrrrvr1r/rzrzwrr1rz)8 __future__rtypingrrrtyping_extensionsrhttpxtypesr r r _typesr r rrrrr_utilsrrr_compatr _resourcerr _responserrrr paginationrrrr _base_clientr!r" types.threadr#types.thread_statsr$types.thread_tracer%__all__r&r'r*rxr2rzrvr1r/rs#"""""%%%%%% WWWWWWWWWWJJJJJJJJJJJJJJJJJJJJJJJJJJJJ%%%%%%99999999  @???????!!!!!!,,,,,,,,,,,, 4 5P P P P P oP P P fP P P P P +P P P f                                      r1