We build Cloud Platforms and AI Solutions for your business.

from langgraph import StateGraph
from rag import retrieve_docs

workflow = StateGraph()

@workflow.node
def analyze_sensor_data(state):
    anomalies = state.detect_anomalies()
    context = retrieve_docs(anomalies)
    return {"context": context}

@workflow.node
def recommend_action(state):
    return llm.invoke(state.context)

workflow.add_edge("analyze", "recommend")
agent = workflow.compile()