Ling0925
/
buster
mirror of https://github.com/buster-so/buster.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

for the most part things are looking good

This commit is contained in:
dal 2025-08-18 11:20:06 -06:00
parent 35e0fc27d7
commit b3cfa35430
No known key found for this signature in database
GPG Key ID: 16F4B0E1E9F61122
12 changed files with 40 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
packages/ai/src/steps/message-post-processing-steps/identify-assumptions-step/identify-assumptions-step.ts
View File

@ -190,7 +190,6 @@ No conversation history available for analysis.`,
maxOutputTokens: 10000,
providerOptions: {
anthropic: {
disableParallelToolCalls: true,
thinking: { type: 'enabled', budgetTokens: 16000 },
},
},

3
packages/ai/src/tools/communication-tools/done-tool/done-tool-start.ts
View File

@ -14,7 +14,10 @@ import {
// Factory function that creates a type-safe callback for the specific agent context
export function createDoneToolStart(context: DoneToolContext, doneToolState: DoneToolState) {
return async function doneToolStart(options: ToolCallOptions): Promise<void> {
// Reset state for new tool call to prevent contamination from previous calls
doneToolState.toolCallId = options.toolCallId;
doneToolState.args = undefined;
doneToolState.finalResponse = undefined;
// Extract files from the tool call responses in messages
if (options.messages) {

4
packages/ai/src/tools/communication-tools/message-user-clarifying-question/message-user-clarifying-question-start.ts
View File

@ -17,8 +17,10 @@ export function createMessageUserClarifyingQuestionStart(
return async (options: ToolCallOptions) => {
const messageId = context.messageId;
// Initialize state
// Reset state for new tool call to prevent contamination from previous calls
state.toolCallId = options.toolCallId;
state.args = '';
state.clarifyingQuestion = undefined;
// If we have a messageId, create initial database entries
if (messageId) {

3
packages/ai/src/tools/communication-tools/respond-without-asset-creation/respond-without-asset-creation-start.ts
View File

@ -17,7 +17,10 @@ export function createRespondWithoutAssetCreationStart(
return async function respondWithoutAssetCreationStart(
options: Pick<ToolCallOptions, 'toolCallId'>
): Promise<void> {
// Reset state for new tool call to prevent contamination from previous calls
state.toolCallId = options.toolCallId;
state.args = undefined;
state.final_response = undefined;
const responseEntry = createRespondWithoutAssetCreationResponseMessage(
state,

4
packages/ai/src/tools/database-tools/execute-sql/execute-sql-start.ts
View File

@ -8,12 +8,14 @@ import {
export function createExecuteSqlStart(state: ExecuteSqlState, context: ExecuteSqlContext) {
return async function executeSqlStart(options: ToolCallOptions): Promise<void> {
// Initialize state
// Reset state for new tool call to prevent contamination from previous calls
state.toolCallId = options.toolCallId;
state.args = '';
state.statements = [];
state.isComplete = false;
state.startTime = Date.now();
state.executionTime = undefined;
state.executionResults = undefined;
// Create initial reasoning entry for SQL execution
const reasoningEntry = createExecuteSqlReasoningEntry(state, options.toolCallId);

6
packages/ai/src/tools/planning-thinking-tools/sequential-thinking-tool/sequential-thinking-tool-start.ts
View File

@ -15,9 +15,13 @@ export function createSequentialThinkingStart(
context: SequentialThinkingContext
) {
return async function sequentialThinkingStart(options: ToolCallOptions): Promise<void> {
// Set the entry ID and start time in state
// Reset state for new tool call to prevent contamination from previous calls
sequentialThinkingState.toolCallId = options.toolCallId;
sequentialThinkingState.startTime = Date.now();
sequentialThinkingState.args = undefined;
sequentialThinkingState.thought = undefined;
sequentialThinkingState.nextThoughtNeeded = undefined;
sequentialThinkingState.thoughtNumber = undefined;
// Create initial reasoning entry with loading status
const reasoningEntry = createSequentialThinkingReasoningMessage(

4
packages/ai/src/tools/visualization-tools/dashboards/create-dashboards-tool/create-dashboards-start.ts
View File

@ -11,8 +11,10 @@ export function createDashboardsStart(
state: CreateDashboardsState
) {
return async (options: ToolCallOptions) => {
// Reset state for new tool call to prevent contamination from previous calls
state.toolCallId = options.toolCallId;
state.startTime = Date.now();
state.argsText = undefined;
state.files = [];
state.startTime = Date.now();
if (context.messageId) {

4
packages/ai/src/tools/visualization-tools/dashboards/modify-dashboards-tool/modify-dashboards-start.ts
View File

@ -11,8 +11,10 @@ export function createModifyDashboardsStart(
state: ModifyDashboardsState
) {
return async (options: ToolCallOptions) => {
// Reset state for new tool call to prevent contamination from previous calls
state.toolCallId = options.toolCallId;
state.startTime = Date.now();
state.argsText = undefined;
state.files = [];
state.startTime = Date.now();
if (context.messageId) {

3
packages/ai/src/tools/visualization-tools/metrics/create-metrics-tool/create-metrics-start.ts
View File

@ -9,6 +9,9 @@ import {
export function createCreateMetricsStart(context: CreateMetricsContext, state: CreateMetricsState) {
return async (options: ToolCallOptions) => {
state.toolCallId = options.toolCallId;
// Reset state for new tool call to prevent contamination from previous calls
state.argsText = undefined;
state.files = [];
state.startTime = Date.now();
if (context.messageId) {

3
packages/ai/src/tools/visualization-tools/metrics/modify-metrics-tool/modify-metrics-start.ts
View File

@ -8,7 +8,10 @@ import type { ModifyMetricsContext, ModifyMetricsState } from './modify-metrics-
export function createModifyMetricsStart(context: ModifyMetricsContext, state: ModifyMetricsState) {
return async (options: ToolCallOptions) => {
// Reset state for new tool call to prevent contamination from previous calls
state.toolCallId = options.toolCallId;
state.argsText = undefined;
state.files = [];
state.startTime = Date.now();
if (context.messageId) {

3
packages/ai/src/tools/visualization-tools/reports/create-reports-tool/create-reports-start.ts
View File

@ -8,7 +8,10 @@ import {
export function createReportsStart(context: CreateReportsContext, state: CreateReportsState) {
return async (options: ToolCallOptions) => {
// Reset state for new tool call to prevent contamination from previous calls
state.toolCallId = options.toolCallId;
state.argsText = undefined;
state.files = [];
state.startTime = Date.now();
if (context.messageId) {

8
packages/ai/src/tools/visualization-tools/reports/modify-reports-tool/modify-reports-start.ts
View File

@ -8,7 +8,15 @@ import type { ModifyReportsContext, ModifyReportsState } from './modify-reports-
export function modifyReportsStart(context: ModifyReportsContext, state: ModifyReportsState) {
return async (options: ToolCallOptions) => {
// Reset state for new tool call to prevent contamination from previous calls
state.toolCallId = options.toolCallId;
state.argsText = undefined;
state.reportId = undefined;
state.reportName = undefined;
state.edits = [];
state.currentContent = undefined;
state.finalContent = undefined;
state.version_number = undefined;
state.startTime = Date.now();
if (context.messageId) {