crewai-agentoath

AgentOath trust protocol integration for CrewAI.

Adds automatic trust receipt generation to CrewAI crews. Every task delegation and completion produces a cryptographically signed receipt, and agents below a trust threshold can be filtered out of delegation.

Installation

pip install crewai-agentoath

For full CrewAI integration (optional):

pip install crewai-agentoath[crewai]

Quick Start

TrustedCrew -- automatic receipts for crew execution

from agentoath import TrustAgent
from crewai_agentoath import TrustedCrew

manager = TrustAgent.create(name="CrewManager", capabilities=["orchestration"])
trusted = TrustedCrew(crew=my_crew, agent_identity=manager)

# Optionally register individual agents with identities
researcher_id = TrustAgent.create(name="Researcher", capabilities=["search"])
trusted.register_agent(researcher_agent, researcher_id)

result = trusted.kickoff()

# Every delegation + completion has a signed receipt
for receipt in trusted.receipts:
    print(receipt.action, receipt.rating, receipt.description)

TrustedAgent -- bind CrewAI agents to AgentOath identities

from crewai_agentoath import TrustedAgent

identity = TrustAgent.create(name="Analyst", capabilities=["analysis"])
trusted = TrustedAgent(crew_agent=analyst_agent, identity=identity)

print(trusted.did)    # did:trust:agent:...
print(trusted.role)   # "Senior Analyst" (from CrewAI)

TaskCallback -- per-task lifecycle receipts

from crewai_agentoath import TaskCallback

cb = TaskCallback(delegator_identity=manager)
cb.on_task_delegated(task, worker_did=worker.did)
cb.on_task_completed(task, worker_did=worker.did, output="report.pdf")
cb.on_task_failed(task, worker_did=worker.did, error="Timeout")

print(len(cb.receipts))  # 3 signed receipts

TrustFilter -- gate delegation by trust score

from crewai_agentoath import TrustFilter

trust_filter = TrustFilter(min_score=0.6)

candidates = [trusted_agent_a, trusted_agent_b, trusted_agent_c]
eligible = trust_filter.filter_agents(candidates, all_receipts)

# Or rank by score
ranked = trust_filter.rank_agents(candidates, all_receipts)
for agent, score in ranked:
    print(f"{agent.name}: {score:.2f}")

Components

License

Apache-2.0