UPSERT_CHECKPOINT_BLOBS_SQL

UPSERT_CHECKPOINT_BLOBS_SQL = '\n    INSERT INTO checkpoint_blobs (
  thread_id,
  checkpoint_ns,
  channel,
  type,
  blob)\n    VALUES (%s,
  %s,
  %s,
  %s,
  %s)\n    ON CONFLICT (thread_id,
  checkpoint_ns,
  channel
) DO UPDATE SET\n        type = EXCLUDED.type,\n        blob = EXCLUDED.blob;\n'