CYPHER_UPSERT_WRITE = '\nMATCH (
c:Checkpoint {checkpoint_id: $checkpoint_id})\nCREATE (w:PendingWrite {\n task_id: $task_id,\n task_path: $task_path,\n idx: $idx,\n channel: $channel,\n type: $type,\n blob: $blob\n})\nCREATE (c)-[:HAS_WRITE]->(w
)\n'