joddlmZddlmZmZddlmZddlmZddlm Z m Z m Z ddl m Z ddlmZmZmZmZmZmZmZdd lmZmZmZdd lmZdd lmZmZdd lm Z m!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/ddl0m1Z1ddgZ2GddeZ3GddeZ4GddZ5GddZ6GddZ7GddZ8y)) 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 eZdZed dZed dZeeeeddded d dZeeeeeeeeeddded d dZ eddded dd Z y)r'ct|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. )ThreadsResourceWithRawResponseselfs u/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/langsmith/_openapi_client/resources/threads.pywith_raw_responsez!ThreadsResource.with_raw_response$s .d33ct|Sze An alternative to `.with_raw_response` that doesn't eagerly read the response body. )$ThreadsResourceWithStreamingResponser-s r/with_streaming_responsez'ThreadsResource.with_streaming_response,s 4D99r1Ncursorfilter page_sizeselects extra_headers extra_query extra_bodytimeoutc |std||jtd|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}/traces thread_id) project_idr7r8r9r:r;r<r=r>query)pageoptionsmodel) ValueError _get_api_listrrr&r#rr ThreadListTracesParams r.rCrDr7r8r9r:r;r<r=r>s r/ list_traceszThreadsResource.list_traces3sZWXaWdef f!! >) T-k:(+'%%&0"("(%.#* .DD   '"  r1 r7r8max_start_timemin_start_timer9rD thread_filter trace_filter tree_filterr;r<r=r>c |jdttt||||||||| d tj t | | | | tdSa 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) r7r8rPrQr9rDrRrSrT)r;r<r=r>post)rGbodyrHrImethod)rKr r$rr ThreadQueryParamsr#r.r7r8rPrQr9rDrRrSrTr;r<r=r>s r/rFzThreadsResource.querysxX!! #.v6 $$&4&4!*",%2$0#. $55 )+Q[el+"  r1r8r;r<r=r>c|std||jtd|t||||t |||dt j tS) 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 rA!/api/v2/threads/{thread_id}/statsrBr: session_idr8rErHcast_to)rJ_getrr#rr ThreadStatsParamsr% r.rCr:rar8r;r<r=r>s r/statszThreadsResource.statssxzWXaWdef fyy = S(+'%%#*&0"( (99   !  r1)returnr,)rhr4)rCstrrDrir7 str | Omitr8rjr9 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 | NotGivenrhz)SyncItemsCursorGetPagination[ThreadTrace])r7rjr8rjrPUnion[str, datetime] | OmitrQrqr9rkrDrjrRrjrSrjrTrjr;rmr<rnr=ror>rprhz%SyncItemsCursorPostPagination[Thread]rCrir: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']]rarir8rjr;rmr<rnr=ror>rprhr% __name__ __module__ __qualname__rr0r5rrrNrFrgr1r/r'r'#s44::"! $:)-$("&;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 r1c eZdZed dZed dZeeeeddded d dZeeeeeeeeeddded d dZ eddded dd Z y)r(ct|Sr+)#AsyncThreadsResourceWithRawResponser-s r/r0z&AsyncThreadsResource.with_raw_responsePs 3488r1ct|Sr3))AsyncThreadsResourceWithStreamingResponser-s r/r5z,AsyncThreadsResource.with_streaming_responseXs 9>>r1Nr6c |std||jtd|ttt ||| | t |||||dtjtSr@) rJrKrrr&r#rr rLrMs r/rNz AsyncThreadsResource.list_traces_sZWXaWdef f!! >) T.{;(+'%%&0"("(%.#* .DD   '"  r1rOc |jdttt||||||||| d tj t | | | | tdSrV)rKr!r$rr rZr#r[s r/rFzAsyncThreadsResource.querysxX!! #/7 $$&4&4!*",%2$0#. $55 )+Q[el+"  r1r\cK|std||jtd|t||||t |||dt j d{td{S77w)r^rAr_rBr`NrErb)rJrdrr#rr rer%rfs r/rgzAsyncThreadsResource.stats(szWXaWdef fYY = S(+'%1#*&0"( (99   !    s$AA4A0A4+A2,A42A4)rhrz)rhr|)rCrirDrir7rjr8rjr9rkr:rlr;rmr<rnr=ror>rprhzGAsyncPaginator[ThreadTrace, AsyncItemsCursorGetPagination[ThreadTrace]])r7rjr8rjrPrqrQrqr9rkrDrjrRrjrSrjrTrjr;rmr<rnr=ror>rprhz>AsyncPaginator[Thread, AsyncItemsCursorPostPagination[Thread]]rrrsrwr1r/r(r(Os99??"! $:)-$("&;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 r1ceZdZddZy)r,c||_t|j|_t|j|_t|j|_yN)_threadsrrNrFrgr.threadss r/__init__z'ThreadsResourceWithRawResponse.__init__|sI 2    - MM  - MM  r1Nrr'rhNonertrurvrrwr1r/r,r,{  r1r,ceZdZddZy)rzc||_t|j|_t|j|_t|j|_yr)rrrNrFrgrs r/rz,AsyncThreadsResourceWithRawResponse.__init__sI 8    3 MM  3 MM  r1Nrr(rhrrrwr1r/rzrzrr1rzceZdZddZy)r4c||_t|j|_t|j|_t|j|_yr)rrrNrFrgrs r/rz-ThreadsResourceWithStreamingResponse.__init__sI 7    2 MM  2 MM  r1Nrrrwr1r/r4r4rr1r4ceZdZddZy)r|c||_t|j|_t|j|_t|j|_yr)rrrNrFrgrs r/rz2AsyncThreadsResourceWithStreamingResponse.__init__sI =    8 MM  8 MM  r1Nrrrwr1r/r|r|rr1r|N)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,rzr4r|rwr1r/rs#%WWJJJJJ%9  @!,, 4 5i oi X i +i X            r1