UPSERT_CHECKPOINT_BLOBS_SQL

UPSERT_CHECKPOINT_BLOBS_SQL = '\n    INSERT INTO checkpoint_blobs (
  thread_id,
  checkpoint_ns,
  channel,
  version,
  type,
  blob)\n    VALUES (%s,
  %s,
  %s,
  %s,
  %s,
  %s)\n    ON CONFLICT (thread_id,
  checkpoint_ns,
  channel,
  version
) DO NOTHING\n'