Remove langsmith overrides

Author: angus-langchain

README.md

@@ -18,35 +18,9 @@ The LangSmith Collector-Proxy addresses these issues by batching multiple spans
 * **Semantic Translation**: Converts GenAI semantic convention attributes to the LangSmith tracing model.
 * **Flexible Batching**: Configurable batching based on either the number of spans or a time interval.
 
-## Getting Started
-
-### Prerequisites
-
-* Kubernetes cluster
-* Helm installed and configured
-
-### Installation
-
-To deploy the LangSmith Collector-Proxy, follow these steps:
-
-1. Add the LangChain Helm repository:
-
-```bash
-helm repo add langchain-ai https://github.com/langchain-ai/helm
-helm repo update
-```
-
-2. Install the Collector-Proxy using Helm:
-
-```bash
-helm install langsmith-collector-proxy langchain-ai/langsmith-collector-proxy --namespace=<your-namespace> --create-namespace
-```
-
-Replace `<your-namespace>` with your desired Kubernetes namespace.
-
 ## Configuration
 
-The Collector-Proxy can be customized via environment variables or Helm chart values:
+The Collector-Proxy can be customized via environment variables:
 
 | Variable             | Description                                    | Default                           |
 | -------------------- | ---------------------------------------------- | --------------------------------- |
@@ -55,36 +29,12 @@ The Collector-Proxy can be customized via environment variables or Helm chart va
 | `LANGSMITH_API_KEY`  | API key for authenticating with LangSmith      | Required                          |
 | `LANGSMITH_PROJECT`  | Default project for tracing data               | Optional                          |
 | `BATCH_SIZE`         | Number of spans per upload batch               | `100`                             |
-| `FLUSH_INTERVAL_MS`  | Time interval (in milliseconds) to flush spans | `5000` (5 seconds)                |
+| `FLUSH_INTERVAL_MS`  | Time interval (in milliseconds) to flush spans | `1000` (1 seconds)                |
 | `MAX_BUFFER_BYTES`   | Maximum uncompressed buffer size               | `10485760` (10MB)                 |
 | `MAX_BODY_BYTES`     | Maximum size of incoming request body          | `209715200` (200MB)               |
 | `MAX_RETRIES`        | Number of retry attempts for failed uploads    | `3`                               |
 | `RETRY_BACKOFF_MS`   | Initial backoff duration in milliseconds       | `100`                             |
 
-### Example Helm Configuration
-
-```yaml
-langsmith:
-  endpoint: "https://api.smith.langchain.com"
-  apiKey: "your-api-key"
-  project: "default-project"
-
-batching:
-  size: 200
-  intervalMs: 1000
-  maxBufferBytes: 10485760
-
-retry:
-  maxAttempts: 5
-  backoffInitialMs: 200
-```
-
-Save this as `values.yaml` and deploy with:
-
-```bash
-helm upgrade --install langsmith-collector-proxy langchain-ai/langsmith-collector-proxy -f values.yaml
-```
-
 ## Usage
 
 

internal/config/config.go

@@ -51,9 +51,9 @@ func Load() Config {
 		// 3. The batch size is reached.
 		// Because zstd compression can be extremely effective, we use the uncompressed size of the buffer to determine how much data
 		// will be sent to LangSmith.
-		BatchSize:      int(envInt64("BATCH_SIZE", 100)), // default 100 runs
-		FlushInterval:  time.Duration(envInt64("FLUSH_INTERVAL_MS", 1000)) * time.Millisecond,
-		MaxBufferBytes: int(envInt64("MAX_BUFFER_BYTES", 10*1024*1024)), // default 10MB
+		BatchSize:      int(envInt64("BATCH_SIZE", 100)),                                      // default 100 runs
+		FlushInterval:  time.Duration(envInt64("FLUSH_INTERVAL_MS", 1000)) * time.Millisecond, // default 1 second
+		MaxBufferBytes: int(envInt64("MAX_BUFFER_BYTES", 10*1024*1024)),                       // default 10MB
 		// Uploader Config
 		MaxRetries:     int(envInt64("MAX_RETRIES", 3)),
 		BackoffInitial: time.Duration(envInt64("RETRY_BACKOFF_MS", 100)) * time.Millisecond,

internal/translator/otel_converter.go

@@ -54,10 +54,6 @@ const (
 	LangSmithTraceName      = "langsmith.trace.name"
 	LangSmithSpanKind       = "langsmith.span.kind"
 	LangSmithMetadataPrefix = "langsmith.metadata"
-	LangSmithRunID          = "langsmith.span.id"
-	LangSmithTraceID        = "langsmith.trace.id"
-	LangSmithDottedOrder    = "langsmith.span.dotted_order"
-	LangSmithParentRunID    = "langsmith.span.parent_id"
 	LangSmithSessionID      = "langsmith.trace.session_id"
 	LangSmithSessionName    = "langsmith.trace.session_name"
 	LangSmithTags           = "langsmith.span.tags"
@@ -265,19 +261,6 @@ func (c *GenAiConverter) ConvertSpan(span *tracesdkpb.Span, genericOtelEnabled b
 		}
 	}
 
-	// Map LangSmith-specific attributes to run fields
-	if traceID, ok := spanAttrs[LangSmithTraceID]; ok {
-		if stringValue, ok := traceID.Value.(*commonpb.AnyValue_StringValue); ok {
-			run.TraceID = strPointer(stringValue.StringValue)
-		}
-	}
-
-	if dottedOrder, ok := spanAttrs[LangSmithDottedOrder]; ok {
-		if stringValue, ok := dottedOrder.Value.(*commonpb.AnyValue_StringValue); ok {
-			run.DottedOrder = strPointer(stringValue.StringValue)
-		}
-	}
-
 	if sessionID, ok := spanAttrs[LangSmithSessionID]; ok {
 		if stringValue, ok := sessionID.Value.(*commonpb.AnyValue_StringValue); ok {
 			run.SessionID = strPointer(stringValue.StringValue)
@@ -290,19 +273,6 @@ func (c *GenAiConverter) ConvertSpan(span *tracesdkpb.Span, genericOtelEnabled b
 		}
 	}
 
-	// Handle LangSmith IDs with priority over OTLP IDs
-	if langsmithRunID, ok := spanAttrs[LangSmithRunID]; ok {
-		if stringValue, ok := langsmithRunID.Value.(*commonpb.AnyValue_StringValue); ok {
-			run.ID = strPointer(stringValue.StringValue)
-		}
-	}
-
-	if langsmithParentRunID, ok := spanAttrs[LangSmithParentRunID]; ok {
-		if stringValue, ok := langsmithParentRunID.Value.(*commonpb.AnyValue_StringValue); ok {
-			run.ParentRunID = strPointer(stringValue.StringValue)
-		}
-	}
-
 	// invocation params
 	for _, modelAttrKey := range TraceLoopInvocationParams {
 		if modelAttr, ok := spanAttrs[modelAttrKey]; ok {