UPSERT_CHECKPOINT_WRITES_SQL

UPSERT_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 UPDATE SET\n        channel = EXCLUDED.channel,\n        type = EXCLUDED.type,\n        blob = EXCLUDED.blob;\n'