Merge branch 'feat-exp-example' into 'mgx_ops'

Feat exp example

See merge request pub/MetaGPT!322

examples/exp_pool/init_exp_pool.py

@@ -46,6 +46,7 @@ async def add_exp(req: str, resp: str, tag: str, metric: Metric = None):
         metric=metric or Metric(score=Score(val=10, reason="Manual")),
     )
     exp_manager = get_exp_manager()
+    exp_manager.config.exp_pool.enabled = True
     exp_manager.config.exp_pool.enable_write = True
     exp_manager.create_exp(exp)
     logger.info(f"New experience created for the request `{req[:10]}`.")
@@ -59,8 +60,10 @@ async def add_exps(exps: list, tag: str):
         tag: A tag for categorizing the experiences.
 
     """
-
-    tasks = [add_exp(req=json.dumps(exp["req"]), resp=exp["resp"], tag=tag) for exp in exps]
+    tasks = [
+        add_exp(req=exp["req"] if isinstance(exp["req"], str) else json.dumps(exp["req"]), resp=exp["resp"], tag=tag)
+        for exp in exps
+    ]
     await asyncio.gather(*tasks)
 
 

metagpt/exp_pool/decorator.py

@@ -35,8 +35,10 @@ def exp_cache(
     Note:
         1. This can be applied to both synchronous and asynchronous functions.
         2. The function must have a `req` parameter, and it must be provided as a keyword argument.
-        3. If `config.exp_pool.enable_read` is False, the decorator will just directly execute the function.
+        3. If `config.exp_pool.enabled` is False, the decorator will just directly execute the function.
         4. If `config.exp_pool.enable_write` is False, the decorator will skip evaluating and saving the experience.
+        5. If `config.exp_pool.enable_read` is False, the decorator will skip reading from the experience pool.
+
 
     Args:
         _func: Just to make the decorator more flexible, for example, it can be used directly with @exp_cache by default, without the need for @exp_cache().