Manually Updating the Graph

1
from zep_cloud import AddNodeItem
2
from zep_cloud.client import Zep
3
4
client = Zep(api_key=API_KEY)
5
6
result = client.graph.add_nodes(
7
    user_id=user_id,  # Optional: You can use graph_id instead of user_id
8
    nodes=[
9
        AddNodeItem(
10
            name="Alice Johnson",
11
            summary="An engineer on the platform team.",
12
            label="Person",
13
            attributes={"role": "Engineer", "active": True},
14
            metadata={"source": "crm"},
15
        )
16
    ],
17
)
18
19
# UUIDs are assigned before the asynchronous task begins.
20
node_uuid = result.nodes[0].uuid_
21
task_id = result.task_id

1
from zep_cloud import AddNodeItem
2
from zep_cloud.client import Zep
3
4
client = Zep(api_key=API_KEY)
5
6
result = client.graph.add_nodes(
7
    graph_id=graph_id,  # Optional: You can use user_id instead of graph_id
8
    nodes=[
9
        AddNodeItem(
10
            uuid_="c2b42bf8-5d3f-4c92-92a6-43d8854a1e5b",
11
            name="Acme Corporation",
12
            summary="An enterprise software company.",
13
            label="Organization",
14
            attributes={"tier": "enterprise"},
15
        ),
16
        AddNodeItem(
17
            uuid_="79166282-3c4d-4d67-a6b6-4da1bd3a2f11",
18
            name="Alice Johnson",
19
            label="Person",
20
            attributes={"role": "Engineer"},
21
        ),
22
    ],
23
)
24
25
node_uuids = [node.uuid_ for node in result.nodes]
26
task_id = result.task_id

1
from zep_cloud.client import Zep
2
3
client = Zep(api_key=API_KEY)
4
5
updated_node = client.graph.node.update(
6
    uuid_=node_uuid,
7
    name="Alice Smith",
8
    summary="A principal engineer on the platform team.",
9
    labels=["Person"],
10
    attributes={
11
        "role": "Principal Engineer",
12
        "legacy_field": None,  # Deletes this attribute
13
    },
14
)

1
from zep_cloud.client import Zep
2
3
client = Zep(api_key=API_KEY)
4
5
updated_edge = client.graph.edge.update(
6
    uuid_=edge_uuid,
7
    name="WORKS_AT",
8
    fact="Alice Smith is a principal engineer at Acme Corporation",
9
    valid_at="2025-01-15T00:00:00Z",
10
    attributes={
11
        "role": "Principal Engineer",
12
        "legacy_field": None,  # Deletes this attribute
13
    },
14
)

1
from zep_cloud.client import Zep
2
3
client = Zep(
4
    api_key=API_KEY,
5
)
6
7
result = client.graph.add_fact_triple(
8
    user_id=user_id,  # Optional: You can use graph_id instead of user_id
9
    fact="Paul met Eric",
10
    fact_name="MET",
11
    target_node_name="Eric Clapton",
12
    source_node_name="Paul",
13
)
14
15
# The result includes a task_id for tracking processing status
16
task_id = result.task_id
17
print(f"Fact triple task ID: {task_id}")

1
import time
2
3
from zep_cloud.client import Zep
4
5
client = Zep(api_key=API_KEY)
6
7
# Add a fact triple
8
result = client.graph.add_fact_triple(
9
    user_id=user_id,
10
    fact="Paul met Eric",
11
    fact_name="MET",
12
    target_node_name="Eric Clapton",
13
    source_node_name="Paul",
14
)
15
16
task_id = result.task_id
17
if task_id is None:
18
    raise RuntimeError("The add fact triple response did not include a task ID")
19
20
# Poll until the task completes
21
while True:
22
    task = client.task.get(task_id=task_id)
23
24
    if task.status == "succeeded":
25
        break
26
    elif task.status == "failed":
27
        raise Exception(f"Task failed: {task.error}")
28
29
    time.sleep(10)
30
31
# Retrieve the created UUIDs from task.params
32
params = task.params or {}
33
edge_uuid = params.get("edge_uuid")
34
source_node_uuid = params.get("source_node_uuid")
35
target_node_uuid = params.get("target_node_uuid")
36
37
print(f"Edge UUID: {edge_uuid}")
38
print(f"Source Node UUID: {source_node_uuid}")
39
print(f"Target Node UUID: {target_node_uuid}")

1
from zep_cloud.client import Zep
2
3
client = Zep(api_key=API_KEY)
4
5
# Assumes your ontology defines:
6
# - Entity type "Person" with properties: { "age": int, "role": text }
7
# - Edge type "WORKS_AT" with properties: { "start_year": int, "department": text }
8
9
result = client.graph.add_fact_triple(
10
    user_id=user_id,
11
    fact="Alice works at Acme Corp",
12
    fact_name="WORKS_AT",                     # matches edge type in ontology
13
    source_node_name="Alice",
14
    source_node_labels=["Person"],            # matches entity type "Person" in ontology
15
    source_node_attributes={
16
        "age": 30,                            # validated: must be int
17
        "role": "Engineer",                   # validated: must be text
18
    },
19
    target_node_name="Acme Corp",
20
    target_node_labels=["Organization"],      # not in ontology — passes through freely
21
    edge_attributes={
22
        "start_year": 2021,                   # validated against WORKS_AT schema
23
        "department": "Engineering",
24
    },
25
)

1
from zep_cloud.client import Zep
2
3
client = Zep(api_key=API_KEY)
4
5
result = client.graph.add_fact_triple(
6
    user_id=user_id,
7
    fact="Alice works at Acme Corp",
8
    fact_name="WORKS_AT",
9
    source_node_name="Alice",
10
    target_node_name="Acme Corp",
11
    metadata={"source": "crm_import", "confidence": 0.95},
12
)