workflow.py

import operator
from langchain_core.messages import BaseMessage
from langgraph.graph import StateGraph, END, START
from typing import TypedDict, Annotated, Sequence
from agents import supervisor_chain,nutritionist_node,workout_coach_node,mental_health_coach_node,members,sleep_coach_node,hydration_coach_node,posture_and_ergonomics_coach_node,injury_prevention_and_recovery_coach_node


# define the state structure for agents
class AgentState(TypedDict):
    messages: Annotated[Sequence[BaseMessage], operator.add]
    next: str

# function to create the workflow graph
def create_workflow():
    workflow = StateGraph(AgentState)
    workflow.add_node("supervisor", action=supervisor_chain) # addign nodes to the graph
    workflow.add_node("nutritionist", action=nutritionist_node)
    workflow.add_node("workout_coach", action=workout_coach_node)
    workflow.add_node("mental_health_coach", action=mental_health_coach_node)
    workflow.add_node("sleep_coach", action=sleep_coach_node)
    workflow.add_node("hydration_coach", action=hydration_coach_node)
    workflow.add_node("posture_and_ergonomics_coach", action=posture_and_ergonomics_coach_node)
    workflow.add_node("injury_prevention_and_recovery_coach", action=injury_prevention_and_recovery_coach_node)

    for member in members:
        workflow.add_edge(start_key=member, end_key="supervisor")

    conditional_map = {k: k for k in members}
    conditional_map["FINISH"] = END


    workflow.add_conditional_edges("supervisor", lambda x: x["next"], conditional_map)
    workflow.add_edge(START, "supervisor")

    graph= workflow.compile()

    return graph