CYPHER_UPSERT_CHECKPOINT_SIMPLE

CYPHER_UPSERT_CHECKPOINT_SIMPLE = '\nMERGE (
  t:Thread {thread_id: $thread_id, checkpoint_ns: $checkpoint_ns})\nCREATE (c:Checkpoint {\n    checkpoint_id: $checkpoint_id,\n    type: $type,\n    checkpoint: $checkpoint,\n    metadata: $metadata,\n    created_at: datetime()\n})\nCREATE (t)-[:HAS_CHECKPOINT]->(c
)\nRETURN c.checkpoint_id as checkpoint_id\n'