- Add a parameter in the run method to accept any streaming callback function - sequential_workflow.py