Getting outputs of a Parallel step in Agno v2

[khanetor]

I have a workflow with a Parallel step as the final step, and when I call print_response, I can see the outputs of all substeps in the parallel step. However, when I call run, I only get the output of the last substep in the parallel step. I saw in the Parallel workflow examples that there is an agent after the parallel step to synthesise the result, but I don't want to waste another agent and llm call to do this, to save cost, and to avoid sending lots of text to llm to do something very trivial, and risk having the content modified. So I have the last step as a function instead. In this function, when calling context.get_last_step_content, I also saw the output of the last substep output.
Eventually, I managed this with

def collect_results(context: StepInput) -> StepOutput:
  results = [output.content for output in context.get_step_output("Parallel step name").steps]
  return StepOutput(...)

This seems unintuitive to me, because we usually expect the output of a Parallel step is a list. Do we have a more elegant way to get the list of outputs of a Parallel step?

[mishramonalisha76]

Hi @khanetor ,Thanks for reaching out.
print_response internally uses run, hence the output should be same .
I tried to run it on my end and was able to get the list of output for all substeps of a parallel step using this print(workflow.run("Write about the latest AI developments")). Can you please confirm once by trying the above code ? Thanks

[kausmeows]

I have a workflow with a Parallel step as the final step, and when I call print_response, I can see the outputs of all substeps in the parallel step. However, when I call run, I only get the output of the last substep in the parallel step. I saw in the Parallel workflow examples that there is an agent after the parallel step to synthesise the result, but I don't want to waste another agent and llm call to do this, to save cost, and to avoid sending lots of text to llm to do something very trivial, and risk having the content modified. So I have the last step as a function instead. In this function, when calling context.get_last_step_content, I also saw the output of the last substep output. Eventually, I managed this with

def collect_results(context: StepInput) -> StepOutput:
  results = [output.content for output in context.get_step_output("Parallel step name").steps]
  return StepOutput(...)

This seems unintuitive to me, because we usually expect the output of a Parallel step is a list. Do we have a more elegant way to get the list of outputs of a Parallel step?

Hi @khanetor we also have this function-

def get_step_content(self, step_name: str) -> Optional[Union[str, Dict[str, str]]]:
        """Get content from a specific previous step by name

        For parallel steps, if you ask for the parallel step name, returns a dict
        with {step_name: content} for each sub-step.
        For other nested steps (Condition, Router, Loop, Steps), returns the deepest content.
        """

so if you do get_step_content() you should see them all

[kausmeows]

https://arc.net/l/quote/dinepzqg