Skip to main content

weave.trace_server_bindings.remote_http_trace_server

API Overview

Classes​

class RemoteHTTPTraceServer​

method __init__​

__init__(
    trace_server_url: str,
    should_batch: bool = False,
    remote_request_bytes_limit: int = 32505856,
    auth: Optional[tuple[str, str]] = None,
    extra_headers: Optional[dict[str, str]] = None
)

method actions_execute_batch​

actions_execute_batch(
    req: Union[ActionsExecuteBatchReq, dict[str, Any]]
) → ActionsExecuteBatchRes

method call_end​

call_end(req: Union[CallEndReq, dict[str, Any]]) → CallEndRes

method call_read​

call_read(req: Union[CallReadReq, dict[str, Any]]) → CallReadRes

method call_start​

call_start(req: Union[CallStartReq, dict[str, Any]]) → CallStartRes

method call_start_batch​

call_start_batch(req: CallCreateBatchReq) → CallCreateBatchRes

method call_update​

call_update(req: Union[CallUpdateReq, dict[str, Any]]) → CallUpdateRes

method calls_delete​

calls_delete(req: Union[CallsDeleteReq, dict[str, Any]]) → CallsDeleteRes

method calls_query​

calls_query(req: Union[CallsQueryReq, dict[str, Any]]) → CallsQueryRes

method calls_query_stats​

calls_query_stats(
    req: Union[CallsQueryStatsReq, dict[str, Any]]
) → CallsQueryStatsRes

method calls_query_stream​

calls_query_stream(
    req: Union[CallsQueryReq, dict[str, Any]]
) → Iterator[CallSchema]

method completions_create​

completions_create(req: CompletionsCreateReq) → CompletionsCreateRes

method completions_create_stream​

completions_create_stream(req: CompletionsCreateReq) → Iterator[dict[str, Any]]

method cost_create​

cost_create(req: Union[CostCreateReq, dict[str, Any]]) → CostCreateRes

method cost_purge​

cost_purge(req: Union[CostPurgeReq, dict[str, Any]]) → CostPurgeRes

method cost_query​

cost_query(req: Union[CostQueryReq, dict[str, Any]]) → CostQueryRes

method ensure_project_exists​

ensure_project_exists(entity: str, project: str) → EnsureProjectExistsRes

method evaluate_model​

evaluate_model(req: EvaluateModelReq) → EvaluateModelRes

method evaluation_status​

evaluation_status(req: EvaluationStatusReq) → EvaluationStatusRes

method feedback_create​

feedback_create(
    req: Union[FeedbackCreateReq, dict[str, Any]]
) → FeedbackCreateRes

method feedback_purge​

feedback_purge(req: Union[FeedbackPurgeReq, dict[str, Any]]) → FeedbackPurgeRes

method feedback_query​

feedback_query(req: Union[FeedbackQueryReq, dict[str, Any]]) → FeedbackQueryRes

method feedback_replace​

feedback_replace(
    req: Union[FeedbackReplaceReq, dict[str, Any]]
) → FeedbackReplaceRes

method file_content_read​

file_content_read(req: FileContentReadReq) → FileContentReadRes

method file_create​

file_create(req: FileCreateReq) → FileCreateRes

method files_stats​

files_stats(req: FilesStatsReq) → FilesStatsRes

classmethod from_env​

from_env(should_batch: bool = False) → RemoteHTTPTraceServer

method get​

get(url: str, *args: Any, **kwargs: Any) → Response

method get_call_processor​

get_call_processor() → Optional[AsyncBatchProcessor]

Custom method not defined on the formal TraceServerInterface to expose the underlying call processor. Should be formalized in a client-side interface.

method obj_create​

obj_create(req: Union[ObjCreateReq, dict[str, Any]]) → ObjCreateRes

method obj_delete​

obj_delete(req: ObjDeleteReq) → ObjDeleteRes

method obj_read​

obj_read(req: Union[ObjReadReq, dict[str, Any]]) → ObjReadRes

method objs_query​

objs_query(req: Union[ObjQueryReq, dict[str, Any]]) → ObjQueryRes

method op_create​

op_create(req: Union[OpCreateReq, dict[str, Any]]) → OpCreateRes

method op_read​

op_read(req: Union[OpReadReq, dict[str, Any]]) → OpReadRes

method ops_query​

ops_query(req: Union[OpQueryReq, dict[str, Any]]) → OpQueryRes

method otel_export​

otel_export(req: OtelExportReq) → OtelExportRes

method post​

post(url: str, *args: Any, **kwargs: Any) → Response

method project_stats​

project_stats(req: ProjectStatsReq) → ProjectStatsRes

method refs_read_batch​

refs_read_batch(req: Union[RefsReadBatchReq, dict[str, Any]]) → RefsReadBatchRes

method server_info​

server_info() → ServerInfoRes

method set_auth​

set_auth(auth: tuple[str, str]) → None

method table_create​

table_create(req: Union[TableCreateReq, dict[str, Any]]) → TableCreateRes

Similar to calls/batch_upsert, we can dynamically adjust the payload size due to the property that table creation can be decomposed into a series of updates. This is useful when the table creation size is too big to be sent in a single request. We can create an empty table first, then update the table with the rows.

method table_query​

table_query(req: Union[TableQueryReq, dict[str, Any]]) → TableQueryRes

method table_query_stats​

table_query_stats(
    req: Union[TableQueryStatsReq, dict[str, Any]]
) → TableQueryStatsRes

method table_query_stats_batch​

table_query_stats_batch(
    req: Union[TableQueryStatsReq, dict[str, Any]]
) → TableQueryStatsRes

method table_query_stream​

table_query_stream(req: TableQueryReq) → Iterator[TableRowSchema]

method table_update​

table_update(req: TableUpdateReq) → TableUpdateRes

Similar to calls/batch_upsert, we can dynamically adjust the payload size due to the property that table updates can be decomposed into a series of updates.

method threads_query_stream​

threads_query_stream(req: ThreadsQueryReq) → Iterator[ThreadSchema]