Add ability to `send_event` to a Worfklow's service ongoing task/run.

run-llama / llama_deploy

Deploy your agentic worfklows to production

https://docs.llamaindex.ai/en/stable/module_guides/llama_deploy/

MIT License

1.86k stars 193 forks source link

Add ability to `send_event` to a Worfklow's service ongoing task/run. #330

Closed nerdai closed 1 month ago

nerdai commented 1 month ago

With current implementation:

User sends event via client.send_event(task_id, session_id, event_def)
EventDefinition contains event_obj_str which is serialized representation of event as well as agent_id
Within the execution of the Workflow, that is under WorkflowService.process_call a background asyncio Task is spawned that deals with passing events to the Workflow.

Testing:

a new e2e test is added
a new unit test to workflow_service has been added

coveralls commented 1 month ago

coverage: 65.613% (+0.1%) from 65.5% when pulling aaca65504cfaa46c1e786e002cc29e179bc1bbc1 on nerdai/add-send_event-to-sessionclient into 73ea5949bbb8e99bacd16d1cada2a444861a9cfa on main.