Function anthropicDataStream

coderd/taskname/taskname.go:332–351

(ctx context.Context, client anthropic.Client, model anthropic.Model, input []aisdk.Message)

}

func anthropicDataStream(ctx context.Context, client anthropic.Client, model anthropic.Model, input []aisdk.Message) (aisdk.DataStream, error) {
	messages, system, err := aisdk.MessagesToAnthropic(input)
	if err != nil {
		return nil, xerrors.Errorf("convert messages to anthropic format: %w", err)
	}

	return aisdk.AnthropicToDataStream(client.Messages.NewStreaming(ctx, anthropic.MessageNewParams{
		Model: model,
		// MaxTokens is set to 100 based on the maximum expected output size.
		// The worst-case JSON output is 134 characters:
		//   - Base structure: 43 chars (including formatting)
		//   - task_name: 27 chars max
		//   - display_name: 64 chars max
		// Using Anthropic's token counting API, this worst-case output tokenizes to 70 tokens.
		// We set MaxTokens to 100 to provide a safety buffer.
		MaxTokens: 100,
		System:    system,
		Messages:  messages,
	})), nil
}