Claude Agent SDK

import asyncio
from claude_agent_sdk import query, ClaudeAgentOptions

async def main():
    async for message in query(
        prompt="""You are a customer support agent that helps customers.

When you need to take important actions like sending emails, updating records,
or making changes that could affect customers, use the submit_task tool from
the datashift MCP server to get human approval first.

For example, before sending any email:
1. Call submit_task with queue_key="outbound-communications"
2. Include the email details in the data field
3. Wait for the task to be reviewed
4. Read the task resource to check if it was approved
5. Only proceed if approved

You decide when human review is needed based on the sensitivity of the action.

---

User request: Send a follow-up email to john@example.com thanking them for their purchase""",
        options=ClaudeAgentOptions(
            mcp_servers={
                "datashift": {
                    "url": "https://mcp.datashift.io/sse",
                    "headers": {
                        "Authorization": "Bearer <your-access-token>"
                    }
                }
            }
        )
    ):
        if hasattr(message, "result"):
            print(message.result)

asyncio.run(main())

async for message in query(
    prompt="""You process and enrich customer data.

When you encounter situations where you're uncertain about data quality
or need human verification, use the Datashift MCP tools:

- submit_task: Submit data for human review
- list_queues: See available review queues
- get_queue_config: Check queue settings

Use queue_key="data-verification" for data quality checks.
Use queue_key="customer-updates" for customer record changes.

You decide when to request review based on:
- Data confidence level
- Potential customer impact
- Regulatory requirements

After submitting a task, the MCP server will notify you when the review
is complete. Read the task resource to get the reviewer's decision.

---

Process and verify the customer data in customers.csv""",
    options=ClaudeAgentOptions(
        allowed_tools=["Read", "Glob"],
        mcp_servers={
            "datashift": {
                "url": "https://mcp.datashift.io/sse",
                "headers": {"Authorization": "Bearer <your-access-token>"}
            }
        }
    )
):
    if hasattr(message, "result"):
        print(message.result)

async for message in query(
    prompt="Review the authentication code for security issues",
    options=ClaudeAgentOptions(
        allowed_tools=["Read", "Glob", "Grep", "Task"],
        mcp_servers={
            "datashift": {
                "url": "https://mcp.datashift.io/sse",
                "headers": {"Authorization": "Bearer <your-access-token>"}
            }
        },
        agents={
            "security-reviewer": AgentDefinition(
                description="Security expert that reviews code and escalates concerns to humans.",
                prompt="""You are a security reviewer. Analyze code for vulnerabilities.

When you find potential security issues, use the Datashift submit_task tool
to get human verification before reporting. Use queue_key="security-reviews".

Include the file path, line numbers, and your analysis in the task data.""",
                tools=["Read", "Glob", "Grep"]
            )
        }
    )
):
    if hasattr(message, "result"):
        print(message.result)