Flow of crews - infinitelly looping

[Adam]

Hi,

I’ve built a flow where a listener kicks off a crew of agents. Nevertheless, the crew seems to be stuck in an infinite loop after it is launched. I set up max_iter parameter and also end flow listener, but nothing helped.

Thank you

[zinyando]

Do you have a method that has the same name as an event that’s being listened to? That usually causes an infinite loop.

If it’s not the case can you share your flow structure, that will provide more context for people to be able to help you.

[Adam]

Thank you for your reaction. Here’s the code that I use to assemble my flow:

class Assistant(Flow[FlowState]):

@start()
def process_email(self):
    sender = self.state.sender
    message = self.state.query
    print(f"Received Email from: {sender}")
    print(f"Processing Message: {message}")

@listen(process_email)
def router_crew(self):
    """Routes the query to the appropriate crew."""
    print("Thinking...")
    query = self.state.query
    result = RouterCrew().router_crew().kickoff(inputs={ ... })
    self.state.path = result.raw
    print(f"Routing Path: {self.state.path}")

@router(router_crew)
def router(self):
    """Routes based on the detected category."""
    if "invoice" in self.state.path:
        return "spreadsheet_crew"
    elif "event" in self.state.path:
        return "event_crew"
    return "end"

@listen("spreadsheet_crew")
def spreadsheet_crew(self):
    """Handles invoice-related queries."""
    print("Spreadsheets Crew launched...")
    self.state.path += ""
    SpreadSheetCrew().spreadsheet_crew().kickoff(inputs={ ... })
    return "end"

@listen("event_crew")
def event_crew(self):
    """Handles event-related queries with date/time context."""
    print("Event Crew launched...")
    self.state.path += ""
    EventCrew().event_crew().kickoff(inputs={ ... })
    return "end"

@listen("end")
def end(self):
    """Ends the flow."""
    print("Flow completed!")

[zinyando]

You have methods and events with the same names. This will cause infinite loops. Rename the events and things will work

@listen("spreadsheet_crew")
def spreadsheet_crew(self):

and

@listen("event_crew")
def event_crew(self):