ޠjoSSKJr SSKJrJr SSKJr SSKJr SSKJ r J r J r SSK J r SSKJrJrJrJrJrJrJr SS KJrJrJr SS KJr SS KJrJr SS KJ r J!r!J"r"J#r# SS K$J%r%J&r&J'r'J(r( SSK)J*r*J+r+ SSK,J-r- SSK.J/r/ SSK0J1r1 SS/r2"SS\5r3"SS\5r4"SS5r5"SS5r6"SS5r7"SS5r8g)) annotations)ListUnion)datetime)Literal)thread_query_paramsthread_stats_paramsthread_list_traces_params)httpx)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"\rSrSr\S Sj5r\S Sj5r\\\\SSS\S.SSjjr \\\\\\\\\SSS\S. SSjjr \SSS\S .SS jjr S r g)r'#c[U5$z This property can be used as a prefix for any HTTP method call to return the raw response object instead of the parsed content. )ThreadsResourceWithRawResponseselfs e/var/www/html/gaurav/venv/lib/python3.13/site-packages/langsmith/_openapi_client/resources/threads.pywith_raw_response!ThreadsResource.with_raw_response$s .d33c[U5$zU An alternative to `.with_raw_response` that doesn't eagerly read the response body. )$ThreadsResourceWithStreamingResponser.s r0with_streaming_response'ThreadsResource.with_streaming_response,s 4D99r3Ncursorfilter page_sizeselects extra_headers extra_query extra_bodytimeoutc U(d[SU<35eUR[SUS9[[[ UUU U [ UUUUUS.[R5S9[S9$ad 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}/traces thread_id) project_idr:r;r<r=r>r?r@rAquery)pageoptionsmodel) ValueError _get_api_listrrr&r#rr ThreadListTracesParams r/rFrGr:r;r<r=r>r?r@rAs r0 list_tracesThreadsResource.list_traces3sZWXaWdef f!! >) T-k:(+'%%&0"("(%.#* .DD   '"  r3 r:r;max_start_timemin_start_timer<rG thread_filter trace_filter tree_filterr>r?r@rAc URS[[[UUUUUUUUU S. [R 5[ XXS9[SS9$a Query threads within a project (session), with cursor-based pagination. Returns threads matching the given time range and optional filters. 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. thread_filter: `thread_filter` narrows results using a LangSmith filter expression evaluated against each complete thread summary. Self-hosted deployments require LangSmith v0.17 or later; unsupported deployments return 501. See https://docs.langchain.com/langsmith/trace-query-syntax#filter-query-language for syntax. trace_filter: `trace_filter` narrows results to threads containing at least one trace whose root run matches this LangSmith filter expression. Trace-level aggregate fields are evaluated using the complete trace summary. Self-hosted deployments require LangSmith v0.17 or later; unsupported deployments return 501. See https://docs.langchain.com/langsmith/trace-query-syntax#filter-query-language for syntax. tree_filter: `tree_filter` narrows results to threads containing at least one trace with a matching run anywhere in its run tree. Self-hosted deployments require LangSmith v0.17 or later; unsupported deployments return 501. 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 z/api/v2/threads/query) r:r;rTrUr<rGrVrWrX)r>r?r@rApost)rJbodyrKrLmethod)rNr r$rr ThreadQueryParamsr#r/r:r;rTrUr<rGrVrWrXr>r?r@rAs r0rIThreadsResource.queryssX!! #.v6 $$&4&4!*",%2$0#. $55 )+Q[+"  r3r;r>r?r@rAcU(d[SU<35eUR[SUS9[UUUU[ UUUS.[ R 5S9[S9$)& 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 rD!/api/v2/threads/{thread_id}/statsrEr= session_idr;rHrKcast_to)rM_getrr#rr ThreadStatsParamsr% r/rFr=rfr;r>r?r@rAs r0statsThreadsResource.statssxzWXaWdef fyy = S(+'%%#*&0"( (99   !  r3)returnr-)ror6)rFstrrGrpr: str | Omitr;rqr< 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 | NonerA'float | httpx.Timeout | None | NotGivenroz)SyncItemsCursorGetPagination[ThreadTrace])r:rqr;rqrTUnion[str, datetime] | OmitrUrxr<rrrGrqrVrqrWrqrXrqr>rtr?rur@rvrArwroz%SyncItemsCursorPostPagination[Thread]rFrpr=aJList[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']]rfrpr;rqr>rtr?rur@rvrArwror% __name__ __module__ __qualname____firstlineno__rr1r7rrrQrIrl__static_attributes__rnr3r0r'r'#s 44::"! $:)-$("&;DUc c  c  c  c c c N&Oc P"Qc R Sc T9Uc V 3Wc P"!6:6: $!%$(#'"&)-$("&;D#b b  b 4 b 4 b b b "b !b  b &b "b  !b "9#b $ /%b |")-$("&;DAP P  P 23P 45P :&;P <"=P > ?P @9AP B CP P r3c"\rSrSr\S Sj5r\S Sj5r\\\\SSS\S.SSjjr \\\\\\\\\SSS\S. SSjjr \SSS\S .SS jjr S r g)r(iOc[U5$r,)#AsyncThreadsResourceWithRawResponser.s r0r1&AsyncThreadsResource.with_raw_responsePs 3488r3c[U5$r5))AsyncThreadsResourceWithStreamingResponser.s r0r7,AsyncThreadsResource.with_streaming_responseXs 9>>r3Nr9c U(d[SU<35eUR[SUS9[[[ UUU U [ UUUUUS.[R5S9[S9$rC) rMrNrrr&r#rr rOrPs r0rQ AsyncThreadsResource.list_traces_sZWXaWdef f!! >) T.{;(+'%%&0"("(%.#* .DD   '"  r3rSc URS[[[UUUUUUUUU S. [R 5[ XXS9[SS9$rZ)rNr!r$rr r^r#r_s r0rIAsyncThreadsResource.queryssX!! #/7 $$&4&4!*",%2$0#. $55 )+Q[+"  r3rac# U(d[SU<35eUR[SUS9[UUUU[ UUUS.[ R 5IShvN S9[S9IShvN $NN7f)rcrDrdrEreNrHrg)rMrirr#rr rjr%rks r0rlAsyncThreadsResource.stats(szWXaWdef fYY = S(+'%1#*&0"( (99   !    s$AA1A-A1(A/)A1/A1rn)ror)ror)rFrprGrpr:rqr;rqr<rrr=rsr>rtr?rur@rvrArwrozGAsyncPaginator[ThreadTrace, AsyncItemsCursorGetPagination[ThreadTrace]])r:rqr;rqrTrxrUrxr<rrrGrqrVrqrWrqrXrqr>rtr?rur@rvrArwroz>AsyncPaginator[Thread, AsyncItemsCursorPostPagination[Thread]]ryrzrnr3r0r(r(Os"99??"! $:)-$("&;DUc c  c  c  c c c N&Oc P"Qc R Sc T9Uc V QWc P"!6:6: $!%$(#'"&)-$("&;D#b b  b 4 b 4 b b b "b !b  b &b "b  !b "9#b $ H%b |")-$("&;DAP P  P 23P 45P :&;P <"=P > ?P @9AP B CP P r3c\rSrSrSSjrSrg)r-i{cXl[UR5Ul[UR5Ul[UR5UlgN)_threadsrrQrIrlr/threadss r0__init__'ThreadsResourceWithRawResponse.__init__|sG 2    - MM  - MM  r3rrQrIrlNrr'roNoner{r|r}r~rrrnr3r0r-r-{  r3r-c\rSrSrSSjrSrg)ricXl[UR5Ul[UR5Ul[UR5Ulgr)rrrQrIrlrs r0r,AsyncThreadsResourceWithRawResponse.__init__sG 8    3 MM  3 MM  r3rNrr(rorrrnr3r0rrrr3rc\rSrSrSSjrSrg)r6icXl[UR5Ul[UR5Ul[UR5Ulgr)rrrQrIrlrs r0r-ThreadsResourceWithStreamingResponse.__init__sG 7    2 MM  2 MM  r3rNrrrnr3r0r6r6rr3r6c\rSrSrSSjrSrg)ricXl[UR5Ul[UR5Ul[UR5Ulgr)rrrQrIrlrs r0r2AsyncThreadsResourceWithStreamingResponse.__init__sG =    8 MM  8 MM  r3rNrrrnr3r0rrrr3rN)9 __future__rtypingrrrtyping_extensionsrtypesr r r _httpxr _typesr rrrrrr_utilsrrr_compatr _resourcerr _responserrrr paginationrrr r! _base_clientr"r# types.threadr$types.thread_statsr%types.thread_tracer&__all__r'r(r-rr6rrnr3r0rs#%WWJJJJJ%9  @!,, 4 5i oi X i +i X            r3