MemoGrafter
enqueueIngest()
Submit conversation ingestion to BullMQ.
What it does
Submit conversation ingestion to BullMQ.
This method requires queue mode and returns after the job is accepted, not after extraction and persistence have finished.
Signature
TypeScript
enqueueIngest(messages: Message[], sessionId: string, options?: IngestOptions): Promise<void>Parameters
messages (Message[]) — Ordered conversation messages to extract memory from.sessionId (string) — The application-owned session whose memory should be read or changed.options? (IngestOptions) — Optional limits, filters, tags, or operation-specific behavior.Result
The requested identifier or text value.
Example
example.ts
await memo.enqueueIngest(messages, "user-42");