From b07a66c9e5a06defac400eb2fabf5420d7ecc973 Mon Sep 17 00:00:00 2001
From: zaihuaji <zaihuaji@gmail.com>
Date: Thu, 11 Dec 2025 18:43:41 -0600
Subject: [PATCH] check 'chkcnd' in PGLOG['DSCHECK']

---
 pyproject.toml                  | 2 +-
 src/rda_python_common/PgDBI.py  | 9 +++++----
 src/rda_python_common/pg_dbi.py | 9 +++++----
 3 files changed, 11 insertions(+), 9 deletions(-)

diff --git a/pyproject.toml b/pyproject.toml
index 8b6c9a3..2c8d965 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "rda_python_common"
-version = "2.0.7"
+version = "2.0.8"
 authors = [
   { name="Zaihua Ji", email="zji@ucar.edu" },
 ]
diff --git a/src/rda_python_common/PgDBI.py b/src/rda_python_common/PgDBI.py
index fca9eba..ca02492 100644
--- a/src/rda_python_common/PgDBI.py
+++ b/src/rda_python_common/PgDBI.py
@@ -323,11 +323,12 @@ def aborttran(autocommit = True):
 #
 def record_dscheck_error(errmsg, logact = PGDBI['EXITLG']):
 
-   cnd = PgLOG.PGLOG['DSCHECK']['chkcnd']
+   check = PgLOG.PGLOG['DSCHECK']
+   chkcnd = check['chkcnd'] if 'chkcnd' in check else "cindex = {}".format(check['cindex'])
+   dflags = check['dflags'] if 'dflags' in check else ''
    if PgLOG.PGLOG['NOQUIT']: PgLOG.PGLOG['NOQUIT'] = 0
-   dflags = PgLOG.PGLOG['DSCHECK']['dflags']
 
-   pgrec = pgget("dscheck", "mcount, tcount, lockhost, pid", cnd, logact)
+   pgrec = pgget("dscheck", "mcount, tcount, lockhost, pid", chkcnd, logact)
    if not pgrec: return 0
    if not pgrec['pid'] and not pgrec['lockhost']: return 0
    (chost, cpid) = PgLOG.current_process_info()
@@ -350,7 +351,7 @@ def record_dscheck_error(errmsg, logact = PGDBI['EXITLG']):
       if pgrec['tcount'] > 1: errmsg = "Try {}: {}".format(pgrec['tcount'], errmsg)
       record['errmsg'] = errmsg
 
-   return pgupdt("dscheck", record, cnd, logact)
+   return pgupdt("dscheck", record, chkcnd, logact)
 
 #
 # local function to log query error
diff --git a/src/rda_python_common/pg_dbi.py b/src/rda_python_common/pg_dbi.py
index ec13057..f2bf4dc 100644
--- a/src/rda_python_common/pg_dbi.py
+++ b/src/rda_python_common/pg_dbi.py
@@ -248,10 +248,11 @@ def aborttran(self, autocommit = True):
    # record error message to dscheck record and clean the lock
    def record_dscheck_error(self, errmsg, logact = None):
       if logact is None: logact = self.PGDBI['EXITLG']
-      cnd = self.PGLOG['DSCHECK']['chkcnd']
+      check = PgLOG.PGLOG['DSCHECK']
+      chkcnd = check['chkcnd'] if 'chkcnd' in check else "cindex = {}".format(check['cindex'])
+      dflags = check['dflags'] if 'dflags' in check else ''
       if self.PGLOG['NOQUIT']: self.PGLOG['NOQUIT'] = 0
-      dflags = self.PGLOG['DSCHECK']['dflags']
-      pgrec = self.pgget("dscheck", "mcount, tcount, lockhost, pid", cnd, logact)
+      pgrec = self.pgget("dscheck", "mcount, tcount, lockhost, pid", chkcnd, logact)
       if not pgrec: return 0
       if not pgrec['pid'] and not pgrec['lockhost']: return 0
       (chost, cpid) = self.current_process_info()
@@ -271,7 +272,7 @@ def record_dscheck_error(self, errmsg, logact = None):
          errmsg = self.break_long_string(errmsg, 512, None, 50, None, 50, 25)
          if pgrec['tcount'] > 1: errmsg = "Try {}: {}".format(pgrec['tcount'], errmsg)
          record['errmsg'] = errmsg
-      return self.pgupdt("dscheck", record, cnd, logact)
+      return self.pgupdt("dscheck", record, chkcnd, logact)
 
    # local function to log query error
    def qelog(self, dberror, sleep, sqlstr, vals, pgcnt, logact = None):