mirror of https://github.com/dapr/dapr-agents.git
29 lines
754 B
Python
29 lines
754 B
Python
from dapr_agents import RandomOrchestrator
|
|
from dotenv import load_dotenv
|
|
import asyncio
|
|
import logging
|
|
|
|
|
|
async def main():
|
|
try:
|
|
random_workflow = RandomOrchestrator(
|
|
name="RandomOrchestrator",
|
|
message_bus_name="messagepubsub",
|
|
state_store_name="workflowstatestore",
|
|
state_key="workflow_state",
|
|
agents_registry_store_name="agentstatestore",
|
|
agents_registry_key="agents_registry",
|
|
max_iterations=3
|
|
).as_service(port=8004)
|
|
|
|
await random_workflow.start()
|
|
except Exception as e:
|
|
print(f"Error starting workflow: {e}")
|
|
|
|
|
|
if __name__ == "__main__":
|
|
load_dotenv()
|
|
|
|
logging.basicConfig(level=logging.INFO)
|
|
|
|
asyncio.run(main()) |