CYPHER_GET_WRITES = '\nMATCH (
c:Checkpoint {checkpoint_id: $checkpoint_id})\n -[:HAS_WRITE]->(w:PendingWrite
)\nRETURN w.task_id as task_id,\n w.task_path as task_path,\n w.channel as channel,\n w.type as type,\n w.blob as blob,\n w.idx as idx\nORDER BY w.idx\n'