[feature]: Introducing async add method aadd (proposal)

[spike-spiegel-21]

Motivation:

https://discord.com/channels/1121119078191480945/1279997338944929915/1280570524589625375

Docs:

The async add method aadd can be used for non-blocking of main thread for I/O bound tasks. This help users to reduce latency significantly.

m = Memory.from_config(config)
async def _main():
    await m.aadd("Likes to play cricket on weekends", user_id="alice", metadata={"category": "hobbies"})
 
asyncio.run(_main())

Demo: Sync

import time
start = time.time()
m.add("I love experimenting with new recipes, especially when cooking fusion dishes.", user_id="alex")
m.add("I often spend hours browsing tech blogs and forums to stay updated on the latest programming trends.", user_id="alex")
m.add("I enjoy solving coding challenges online, especially when I find clever solutions to tough problems.", user_id="alex")
print(f"Time taken: {time.time() - start}")

Time taken: 29.755067825317383
Extracted memories:

['Loves experimenting with new recipes', 'Likes finding clever solutions to tough problems', 'Often spends hours browsing tech blogs and forums to stay updated on the latest programming trends', 'Enjoys cooking fusion dishes', 'Enjoys solving coding challenges online']

Demo: Async

import asyncio
async def _main():
    await asyncio.gather(
        # await m.add()
        m.aadd("I love experimenting with new recipes, especially when cooking fusion dishes.", user_id="harry"),
        m.aadd("I often spend hours browsing tech blogs and forums to stay updated on the latest programming trends.", user_id="harry"),
        m.aadd("I enjoy solving coding challenges online, especially when I find clever solutions to tough problems.", user_id="harry")
    )
start = time.time()
asyncio.run(_main())
print(f"Time taken: {time.time() - start}")

Time taken: 11.030951976776123
Extracted memories:

['Enjoys cooking fusion dishes', 'Often spends hours browsing tech blogs and forums to stay updated on the latest programming trends', 'Enjoys solving coding challenges online', 'Loves experimenting with new recipes', 'Likes finding clever solutions to tough problems']

[spike-spiegel-21]

Hi @deshraj, Did only for openai client. Going ahead will be implementing for more I/O bound tasks and wide support.

1. vector db operations
2. graph db operations