[Bug] _context_join_fn() missing 1 required positional argument: 'chunks'

[david101-hunter]

Search before asking

• I had searched in the issues and found no similar issues.

Operating system information

Linux

Python version information

=3.11

DB-GPT version

main

Related scenes

• Chat Data
• Chat Excel
• Chat DB
• Chat Knowledge
• Model Management
• Dashboard
• Plugins

Installation Information

• Installation From Source

• Docker Installation

• Docker Compose Installation

• Cluster Installation

• AutoDL Image

• Other

Device information

Device CPU

Models information

LLM: Proxy Ollama: qwen:0.5b
Embedding: Proxy Ollama: nomic-embed-text

What happened

I run simple_rag_retriever_example.py

It raise a error

nal Server Error
ERROR:    Exception in ASGI application
Traceback (most recent call last):
  File "/media/manhdt4/sda1/miniconda3/envs/dbgpt/lib/python3.10/site-packages/uvicorn/protocols/http/httptools_impl.py", line 401, in run_asgi
    result = await app(  # type: ignore[func-returns-value]
  File "/media/manhdt4/sda1/miniconda3/envs/dbgpt/lib/python3.10/site-packages/uvicorn/middleware/proxy_headers.py", line 60, in __call__
    return await self.app(scope, receive, send)
  File "/media/manhdt4/sda1/miniconda3/envs/dbgpt/lib/python3.10/site-packages/fastapi/applications.py", line 1054, in __call__
    await super().__call__(scope, receive, send)
  File "/media/manhdt4/sda1/miniconda3/envs/dbgpt/lib/python3.10/site-packages/starlette/applications.py", line 113, in __call__
    await self.middleware_stack(scope, receive, send)
  File "/media/manhdt4/sda1/miniconda3/envs/dbgpt/lib/python3.10/site-packages/starlette/middleware/errors.py", line 187, in __call__
    raise exc
  File "/media/manhdt4/sda1/miniconda3/envs/dbgpt/lib/python3.10/site-packages/starlette/middleware/errors.py", line 165, in __call__
    await self.app(scope, receive, _send)
  File "/media/manhdt4/sda1/miniconda3/envs/dbgpt/lib/python3.10/site-packages/starlette/middleware/exceptions.py", line 62, in __call__
    await wrap_app_handling_exceptions(self.app, conn)(scope, receive, send)
  File "/media/manhdt4/sda1/miniconda3/envs/dbgpt/lib/python3.10/site-packages/starlette/_exception_handler.py", line 53, in wrapped_app
    raise exc
  File "/media/manhdt4/sda1/miniconda3/envs/dbgpt/lib/python3.10/site-packages/starlette/_exception_handler.py", line 42, in wrapped_app
    await app(scope, receive, sender)
  File "/media/manhdt4/sda1/miniconda3/envs/dbgpt/lib/python3.10/site-packages/starlette/routing.py", line 715, in __call__
    await self.middleware_stack(scope, receive, send)
  File "/media/manhdt4/sda1/miniconda3/envs/dbgpt/lib/python3.10/site-packages/starlette/routing.py", line 735, in app
    await route.handle(scope, receive, send)
  File "/media/manhdt4/sda1/miniconda3/envs/dbgpt/lib/python3.10/site-packages/starlette/routing.py", line 288, in handle
    await self.app(scope, receive, send)
  File "/media/manhdt4/sda1/miniconda3/envs/dbgpt/lib/python3.10/site-packages/starlette/routing.py", line 76, in app
    await wrap_app_handling_exceptions(app, request)(scope, receive, send)
  File "/media/manhdt4/sda1/miniconda3/envs/dbgpt/lib/python3.10/site-packages/starlette/_exception_handler.py", line 53, in wrapped_app
    raise exc
  File "/media/manhdt4/sda1/miniconda3/envs/dbgpt/lib/python3.10/site-packages/starlette/_exception_handler.py", line 42, in wrapped_app
    await app(scope, receive, sender)
  File "/media/manhdt4/sda1/miniconda3/envs/dbgpt/lib/python3.10/site-packages/starlette/routing.py", line 73, in app
    response = await f(request)
  File "/media/manhdt4/sda1/miniconda3/envs/dbgpt/lib/python3.10/site-packages/fastapi/routing.py", line 301, in app
    raw_response = await run_endpoint_function(
  File "/media/manhdt4/sda1/miniconda3/envs/dbgpt/lib/python3.10/site-packages/fastapi/routing.py", line 212, in run_endpoint_function
    return await dependant.call(**values)
  File "/media/manhdt4/sda1/db-gpt/DB-GPT/dbgpt/core/awel/trigger/http_trigger.py", line 676, in route_function
    return await _trigger_dag_func(body)
  File "/media/manhdt4/sda1/db-gpt/DB-GPT/dbgpt/core/awel/trigger/http_trigger.py", line 607, in _trigger_dag_func
    return await _trigger_dag(
  File "/media/manhdt4/sda1/db-gpt/DB-GPT/dbgpt/core/awel/trigger/http_trigger.py", line 729, in _trigger_dag
    return await end_node.call(call_data=body)
  File "/media/manhdt4/sda1/db-gpt/DB-GPT/dbgpt/core/awel/operators/base.py", line 283, in call
    out_ctx = await self._runner.execute_workflow(
  File "/media/manhdt4/sda1/db-gpt/DB-GPT/dbgpt/core/awel/runner/local_runner.py", line 114, in execute_workflow
    await self._execute_node(
  File "/media/manhdt4/sda1/db-gpt/DB-GPT/dbgpt/core/awel/runner/local_runner.py", line 143, in _execute_node
    await self._execute_node(
  File "/media/manhdt4/sda1/db-gpt/DB-GPT/dbgpt/core/awel/runner/local_runner.py", line 143, in _execute_node
    await self._execute_node(
  File "/media/manhdt4/sda1/db-gpt/DB-GPT/dbgpt/core/awel/runner/local_runner.py", line 143, in _execute_node
    await self._execute_node(
  [Previous line repeated 1 more time]
  File "/media/manhdt4/sda1/db-gpt/DB-GPT/dbgpt/core/awel/runner/local_runner.py", line 213, in _execute_node
    raise e
  File "/media/manhdt4/sda1/db-gpt/DB-GPT/dbgpt/core/awel/runner/local_runner.py", line 192, in _execute_node
    await node._run(dag_ctx, task_ctx.log_id)
  File "/media/manhdt4/sda1/db-gpt/DB-GPT/dbgpt/core/awel/operators/base.py", line 248, in _run
    return await self._do_run(dag_ctx)
  File "/media/manhdt4/sda1/db-gpt/DB-GPT/dbgpt/core/awel/operators/common_operator.py", line 62, in _do_run
    input_ctx: InputContext = await curr_task_ctx.task_input.map_all(
  File "/media/manhdt4/sda1/db-gpt/DB-GPT/dbgpt/core/awel/task/task_impl.py", line 580, in map_all
    map_res = map_func(*outputs)
TypeError: _context_join_fn() missing 1 required positional argument: 'chunks'

What you expected to happen

How can I fix that?

How to reproduce

1. python examples/rag/simple_rag_retriever_example.py
2. call from postman

curl --location 'http://localhost:5555/api/v1/awel/trigger/examples/rag/retrieve' \
--header 'Content-Type: application/json' \
--data '{ 
    "query": "what is awel talk about?"
}'

Additional context

No response

Are you willing to submit PR?

• Yes I am willing to submit a PR!