INSERT_CHECKPOINT_WRITES_SQL

INSERT_CHECKPOINT_WRITES_SQL = '\n    INSERT INTO checkpoint_writes (
  thread_id,
  checkpoint_ns,
  checkpoint_id,
  task_id,
  task_path,
  idx,
  channel,
  type,
  blob)\n    VALUES (%s,
  %s,
  %s,
  %s,
  %s,
  %s,
  %s,
  %s,
  %s)\n    ON CONFLICT (thread_id,
  checkpoint_ns,
  checkpoint_id,
  task_id,
  idx
) DO NOTHING\n'