-
Notifications
You must be signed in to change notification settings - Fork 780
Add CrewAI and workflow documentation #4973
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Changes from 2 commits
4771434
4d446a2
daa8699
0fa881b
4b72a3a
45c76b4
7de512c
File filter
Filter by extension
Conversations
Jump to
Diff view
Diff view
There are no files selected for viewing
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,11 @@ | ||
| --- | ||
| type: docs | ||
| title: "CrewAI" | ||
| linkTitle: "CrewAI" | ||
| weight: 25 | ||
| description: "Dapr first-class integrations with CrewAI Agents" | ||
| --- | ||
|
|
||
| ### What is the Dapr CrewAI integration? | ||
|
|
||
| Dapr provides APIs for developers looking to build CrewAI agents that scale and operate reliably in production. Dapr provides first class integrations that range from agent session management to connecting agents via pub/sub and orchestrating agentic workflows. | ||
| Original file line number | Diff line number | Diff line change | ||||
|---|---|---|---|---|---|---|
| @@ -0,0 +1,204 @@ | ||||||
| --- | ||||||
| type: docs | ||||||
| title: "CrewAI Workflows" | ||||||
| linkTitle: "CrewAI Workflows" | ||||||
| weight: 25 | ||||||
| description: "How to run CrewAI agents with durable, fault-tolerant execution using Dapr Workflows" | ||||||
| --- | ||||||
|
|
||||||
| ## Overview | ||||||
|
|
||||||
| Dapr Workflows make it possible to run CrewAI agents **reliably**, **durably**, and **with built-in resiliency**. | ||||||
| By orchestrating CrewAI tasks with the Dapr Workflow engine, developers can: | ||||||
|
|
||||||
| - Ensure long-running CrewAI work survives crashes and restarts | ||||||
|
yaron2 marked this conversation as resolved.
Outdated
|
||||||
| - Get automatic checkpoints, retries, and state recovery | ||||||
|
yaron2 marked this conversation as resolved.
Outdated
|
||||||
| - Run each CrewAI task as a durable activity | ||||||
|
yaron2 marked this conversation as resolved.
Outdated
|
||||||
| - Observe execution through tracing, metrics, and structured logs | ||||||
|
yaron2 marked this conversation as resolved.
Outdated
|
||||||
|
|
||||||
| This guide walks through orchestrating multiple CrewAI tasks using Dapr Workflows, ensuring each step is run *exactly once* even if the process restarts. | ||||||
|
|
||||||
| ## Getting Started | ||||||
|
|
||||||
| Initialize Dapr locally to set up a self-hosted environment for development. This process installs the Dapr sidecar binaries, provisions the workflow engine, and prepares a default components directory. For full details, see the official [guide on initializing Dapr locally]({{% ref install-dapr-selfhost.md %}}). | ||||||
|
yaron2 marked this conversation as resolved.
Outdated
|
||||||
|
|
||||||
| Initialize Dapr: | ||||||
|
|
||||||
| ```bash | ||||||
| dapr init | ||||||
| ``` | ||||||
|
|
||||||
| Verify that daprio/dapr, openzipkin/zipkin, and redis are running: | ||||||
|
|
||||||
| ```bash | ||||||
| docker ps | ||||||
| ``` | ||||||
|
|
||||||
| ### Install Python | ||||||
|
|
||||||
| {{% alert title="Note" color="info" %}} | ||||||
| Make sure you have Python already installed. `Python >=3.10`. For installation instructions, visit the official [Python installation guide](https://www.python.org/downloads/). | ||||||
| {{% /alert %}} | ||||||
|
|
||||||
| ### Install Dependencies | ||||||
|
|
||||||
| ```bash | ||||||
| pip install dapr dapr-ext-workflow crewai | ||||||
| ``` | ||||||
|
|
||||||
| ### Create a Python Virtual Environment (recommended) | ||||||
|
|
||||||
| ```bash | ||||||
| python -m venv .venv | ||||||
| source .venv/bin/activate # Windows: .venv\Scripts\activate | ||||||
| ``` | ||||||
|
|
||||||
| ### Create a Workflow to Run CrewAI Tasks | ||||||
|
|
||||||
| Create a file named crewai_workflow.py and paste the following: | ||||||
|
|
||||||
| ```python | ||||||
| from dapr.ext.workflow import ( | ||||||
| WorkflowRuntime, | ||||||
| DaprWorkflowContext, | ||||||
| WorkflowActivityContext, | ||||||
| DaprWorkflowClient, | ||||||
| ) | ||||||
| from crewai import Agent, Task, Crew | ||||||
| import time | ||||||
|
|
||||||
| wfr = WorkflowRuntime() | ||||||
|
|
||||||
| # ------------------------------------------------------------ | ||||||
| # 1. Define Agent, Tasks, and Task Dictionary | ||||||
| # ------------------------------------------------------------ | ||||||
| agent = Agent( | ||||||
| role="Research Analyst", | ||||||
| goal="Research and summarize impactful technology updates.", | ||||||
| backstory="A skilled analyst who specializes in researching and summarizing technology topics.", | ||||||
| ) | ||||||
|
|
||||||
| tasks = { | ||||||
| "latest_ai_news": Task( | ||||||
| description="Find the latest news about artificial intelligence.", | ||||||
| expected_output="A 3-paragraph summary of the top 3 stories.", | ||||||
| agent=agent, | ||||||
| ), | ||||||
| "ai_startup_launches": Task( | ||||||
| description="Summarize the most impactful AI startup launches in the last 6 months.", | ||||||
| expected_output="A list summarizing 2 AI startups with links.", | ||||||
| agent=agent, | ||||||
| ), | ||||||
| "ai_policy_updates": Task( | ||||||
| description="Summarize the newest AI government policy and regulation updates.", | ||||||
| expected_output="A bullet-point list summarizing the latest policy changes.", | ||||||
| agent=agent, | ||||||
| ), | ||||||
| } | ||||||
|
|
||||||
| # ------------------------------------------------------------ | ||||||
| # 2. Activity — runs ONE task by name | ||||||
| # ------------------------------------------------------------ | ||||||
| @wfr.activity(name="run_task") | ||||||
| def run_task_activity(ctx: WorkflowActivityContext, task_name: str): | ||||||
| print(f"Running CrewAI task: {task_name}", flush=True) | ||||||
|
|
||||||
| task = tasks[task_name] | ||||||
|
|
||||||
| # Create a Crew for just this one task | ||||||
| temp_crew = Crew(agents=[agent], tasks=[task]) | ||||||
|
|
||||||
| # kickoff() works across CrewAI versions | ||||||
| result = temp_crew.kickoff() | ||||||
|
|
||||||
| return str(result) | ||||||
|
|
||||||
| # ------------------------------------------------------------ | ||||||
| # 3. Workflow — orchestrates tasks durably | ||||||
| # ------------------------------------------------------------ | ||||||
| @wfr.workflow(name="crewai_multi_task_workflow") | ||||||
| def crewai_workflow(ctx: DaprWorkflowContext): | ||||||
| print("Starting multi-task CrewAI workflow", flush=True) | ||||||
|
|
||||||
| latest_news = yield ctx.call_activity(run_task_activity, input="latest_ai_news") | ||||||
| startup_summary = yield ctx.call_activity(run_task_activity, input="ai_startup_launches") | ||||||
| policy_updates = yield ctx.call_activity(run_task_activity, input="ai_policy_updates") | ||||||
|
|
||||||
| return { | ||||||
| "latest_news": latest_news, | ||||||
| "startup_summary": startup_summary, | ||||||
| "policy_updates": policy_updates, | ||||||
| } | ||||||
|
|
||||||
| # ------------------------------------------------------------ | ||||||
| # 4. Runtime + Client (entry point) | ||||||
| # ------------------------------------------------------------ | ||||||
| if __name__ == "__main__": | ||||||
| wfr.start() | ||||||
|
|
||||||
| client = DaprWorkflowClient() | ||||||
| instance_id = "crewai-multi-01" | ||||||
|
|
||||||
| client.schedule_new_workflow( | ||||||
| workflow=crewai_workflow, | ||||||
| input=None, | ||||||
| instance_id=instance_id | ||||||
| ) | ||||||
|
|
||||||
| state = client.wait_for_workflow_completion(instance_id, timeout_in_seconds=60) | ||||||
| print(state.serialized_output) | ||||||
| ``` | ||||||
|
|
||||||
| ### Create the Workflow Database Component | ||||||
|
|
||||||
| Dapr Workflows persist durable state using any [Dapr state store]({{% ref supported-state-stores %}}) that supports workflows. | ||||||
| Create a components directory, then create the file workflowstore.yaml: | ||||||
|
|
||||||
| ```yaml | ||||||
| apiVersion: dapr.io/v1alpha1 | ||||||
| kind: Component | ||||||
| metadata: | ||||||
| name: statestore | ||||||
|
Member
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more.
Suggested change
Member
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. can we keep these names consistent. Mostly we use workflowstatestore in the quickstarts? Also I could not find the reference to this component in the code, so how does it get used? This should be set by the 'DaprWorkflowClient'
Member
Author
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more. No, this has nothing to do with |
||||||
| spec: | ||||||
| type: state.redis | ||||||
| version: v1 | ||||||
| metadata: | ||||||
| - name: redisHost | ||||||
| value: localhost:6379 | ||||||
| - name: redisPassword | ||||||
| value: "" | ||||||
| - name: actorStateStore | ||||||
| value: "true" | ||||||
| ``` | ||||||
|
|
||||||
| This component stores: | ||||||
|
|
||||||
| * Checkpoints | ||||||
|
yaron2 marked this conversation as resolved.
Outdated
|
||||||
| * Execution history | ||||||
| * Deterministic resumption state | ||||||
| * Final output data | ||||||
|
|
||||||
| ### Set a CrewAI LLM Provider | ||||||
|
|
||||||
| CrewAI needs an LLM configuration or token to run. See instructions [here](https://docs.crewai.com/en/concepts/llms#setting-up-your-llm). | ||||||
|
|
||||||
| ### Run the Workflow | ||||||
|
|
||||||
| Launch the CrewAI workflow using the Dapr CLI: | ||||||
|
|
||||||
| ```bash | ||||||
| dapr run \ | ||||||
| --app-id crewaiwf \ | ||||||
| --dapr-grpc-port 50001 \ | ||||||
| --resources-path ./components \ | ||||||
| -- python3 ./crewai_workflow.py | ||||||
| ``` | ||||||
|
|
||||||
| As the workflow runs, each CrewAI task is executed as a durable activity. | ||||||
| If the process crashes, the workflow resumes exactly where it left off. | ||||||
|
yaron2 marked this conversation as resolved.
Outdated
|
||||||
|
|
||||||
| Open Zipkin to view workflow traces: | ||||||
|
|
||||||
| ``` | ||||||
| http://localhost:9411 | ||||||
| ``` | ||||||
Uh oh!
There was an error while loading. Please reload this page.