Spaces:
No application file
No application file
| import requests | |
| import json | |
| def call_mcp(tool, params=None): | |
| response = requests.post( | |
| 'http://localhost:8000/mcp', | |
| headers={'X-API-Key': 'dev-key-123', 'Content-Type': 'application/json'}, | |
| json={'tool': tool, 'params': params or {}} | |
| ) | |
| return response.json() | |
| # Create demo workflow | |
| workflow = call_mcp('write_graph', { | |
| 'action': 'create_node', | |
| 'label': 'Workflow', | |
| 'properties': { | |
| 'id': 'demo-workflow-1', | |
| 'name': 'Entity Resolution Demo', | |
| 'status': 'active', | |
| 'max_iterations': 10, | |
| 'current_iteration': 0 | |
| } | |
| }) | |
| print(f'Created workflow: {workflow}') | |
| # Create three instructions with parameters | |
| instructions = [ | |
| { | |
| 'id': 'inst-1', | |
| 'sequence': 1, | |
| 'type': 'discover_schema', | |
| 'status': 'pending', | |
| 'pause_duration': 300, | |
| 'parameters': '{}' | |
| }, | |
| { | |
| 'id': 'inst-2', | |
| 'sequence': 2, | |
| 'type': 'generate_sql', | |
| 'status': 'pending', | |
| 'pause_duration': 300, | |
| 'parameters': json.dumps({'question': 'Show all customers who have placed orders'}) | |
| }, | |
| { | |
| 'id': 'inst-3', | |
| 'sequence': 3, | |
| 'type': 'review_results', | |
| 'status': 'pending', | |
| 'pause_duration': 300, | |
| 'parameters': '{}' | |
| } | |
| ] | |
| for inst in instructions: | |
| result = call_mcp('write_graph', { | |
| 'action': 'create_node', | |
| 'label': 'Instruction', | |
| 'properties': inst | |
| }) | |
| print(f'Created instruction: {inst["id"]}') | |
| print('✅ Seeding complete!') |