Skip to content

Commit ce3209f

Browse files
committed
fix(floware): get input from kwargs
1 parent b8d14e9 commit ce3209f

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

wavefront/server/modules/tools_module/tools_module/utils/message_processor_fn.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ async def execute_message_processor_fn(message_processor_id: str, **kwargs) -> s
1818
# Remove message_processor_id from kwargs (it's not part of input_data)
1919
input_data = {k: v for k, v in kwargs.items() if k != 'message_processor_id'}
2020

21-
payload = ExecuteMessageProcessorPayload(input_data=input_data)
21+
payload = ExecuteMessageProcessorPayload(input_data=input_data['kwargs'])
2222
response = await execute_message_processor(message_processor_id, payload)
2323

2424
response_body_bytes = response.body

0 commit comments

Comments
 (0)