await step.do("process-events", async () => {
const eventsGroupedBySomething = [[], [], [], [], [], []]; // potentially ~10 groups with 100s of events each
for (const events of eventsGroupedBySomething) {
for (let i = 0; i < events.length; i++) {
const event = events[i]!;
const { embedding, summary } = await generateEventSummary(event);
await db
.insert(schema.eventVector)
.values({ id: nanoid(), eventId: event.id, embedding, summary });
}
}
});
await step.do("process-events", async () => {
const eventsGroupedBySomething = [[], [], [], [], [], []]; // potentially ~10 groups with 100s of events each
for (const events of eventsGroupedBySomething) {
for (let i = 0; i < events.length; i++) {
const event = events[i]!;
const { embedding, summary } = await generateEventSummary(event);
await db
.insert(schema.eventVector)
.values({ id: nanoid(), eventId: event.id, embedding, summary });
}
}
});