CrewAI lets you define multi-agent “crews” with roles, goals, and tasks that collaborate to complete work; integrating CrewAI with ZenML wraps those crews in reproducible pipelines with artifact tracking, orchestration, and an easy path from local experiments to production.
from zenml import ExternalArtifact, pipeline, step
from crewai_agent import crew
@step
def run_crewai(query: str) -> str:
result = crew.kickoff(inputs={"city": query})
return str(result)
@pipeline
def crewai_travel_pipeline() -> str:
q = ExternalArtifact(value="Berlin")
return run_crewai(q.value)
if __name__ == "__main__":
print(crewai_travel_pipeline())Expand your ML pipelines with more than 50 ZenML Integrations