Skip to content

Commit 385de10

Browse files
ci-botyann300
authored andcommitted
fix logging
1 parent bc7408e commit 385de10

File tree

1 file changed

+10
-12
lines changed

1 file changed

+10
-12
lines changed

libs/remix-ai-core/src/remix-mcp-server/handlers/AmpHandler.ts

Lines changed: 10 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -71,20 +71,18 @@ async function performAmpQuery<T = any>(
7171
baseUrl?: string,
7272
authToken?: string
7373
): Promise<Array<T>> {
74-
return await new Promise<Array<T>>(async (resolve, reject) => {
75-
try {
76-
const ampClient = await createAmpClient(baseUrl, authToken);
77-
const data: Array<T> = [];
78-
79-
for await (const batch of ampClient.query(query)) {
80-
data.push(...batch);
81-
}
74+
try {
75+
const ampClient = await createAmpClient(baseUrl, authToken)
76+
const data: Array<T> = []
8277

83-
resolve(data);
84-
} catch (error) {
85-
reject(error);
78+
for await (const batch of ampClient.query(query)) {
79+
data.push(...batch)
8680
}
87-
});
81+
82+
return data
83+
} catch (error) {
84+
throw error
85+
}
8886
}
8987

9088
/**

0 commit comments

Comments
 (0)