AutoGen and CrewAI (March 2026)

from crewai.flow.flow import Flow, listen, start

class ContentFlow(Flow):
    @start()
    def research_topic(self):
        # Returns research output
        return research_crew.kickoff({"topic": self.state["topic"]})
    
    @listen(research_topic)
    def write_article(self, research):
        # Triggered after research completes
        return writing_crew.kickoff({"research": research})
    
    @listen(write_article)
    def publish(self, article):
        # Final step
        return publisher.publish(article)

# AutoGen 0.4: AgentChat API
from autogen_agentchat.agents import AssistantAgent, UserProxyAgent
from autogen_agentchat.teams import RoundRobinGroupChat
from autogen_ext.models import OpenAIChatCompletionClient

model_client = OpenAIChatCompletionClient(model="gpt-4o")

coder = AssistantAgent(
    "Coder",
    model_client=model_client,
    system_message="You write Python code."
)
reviewer = AssistantAgent(
    "Reviewer",
    model_client=model_client,
    system_message="You review code for bugs and style."
)

team = RoundRobinGroupChat([coder, reviewer], max_turns=4)

# Async-native
async def run():
    result = await team.run(task="Write a binary search function.")
    print(result.messages[-1].content)