import requests, os
ORCH = os.environ.get("MOE_BASE_URL", "https://moe-admin.local")
r = requests.get(f"{ORCH}/v1/graph/knowledge/export",
params={"min_trust": 0.5, "domains": "kg-physics"})
bundle = r.json()
print(len(bundle.get("entities", [])), "entities")
import requests
ORCH = "https://moe-admin.local"
bundle = {"@context": "moe", "entities": [{"name": "Test"}]}
r = requests.post(f"{ORCH}/v1/graph/knowledge/import/pending",
json={"bundle": bundle, "source_tag": "notebook-test"})
print(r.json()) # {"status": "pending", "branch": "pending/..."}
import requests
r = requests.get("https://moe-admin.local/v1/graph/search",
params={"q": "Einstein", "limit": 5})
for hit in r.json().get("results", []):
print(hit["name"], "-", hit.get("source"))
import requests
r = requests.post("https://moe-admin.local/api/explorer/cypher",
json={"query": "MATCH (e:Entity) RETURN e.name LIMIT 10"})
data = r.json()
for row in data.get("rows", []):
print(row)
# OpenLineage runs from Marquez (Phase 16)
import requests
r = requests.get("https://moe-admin.local/api/codex/runs?limit=10")
for run in r.json().get("runs", []):
print(f"{run['startedAt']} {run['job']} {run['state']}")