fix(ephemeral): increase max_stack_depth

RHINENG-8335

conf/reposcan.env

@@ -35,3 +35,5 @@ SYNC_CVE_MAP=yes
 SYNC_CPE=yes
 SYNC_OVAL=yes
 SYNC_CSAF=yes
+
+PG_MAX_STACK_DEPTH=6144

deploy/clowdapp.yaml

@@ -147,6 +147,8 @@ objects:
               value: ${{CW_ENABLED}}
             - name: INIT_CONTAINER
               value: "true"
+            - name: PG_MAX_STACK_DEPTH
+              value: ${PG_MAX_STACK_DEPTH}
         command:
         - /vmaas/entrypoint.sh
         - reposcan
@@ -482,3 +484,5 @@ parameters:
   value: "changes.csv"
 - name: CSAF_SYNC_ALL_FILES  # sync all csaf files, not only those which are changed
   value: "false"
+- name: PG_MAX_STACK_DEPTH
+  value: ''

vmaas/common/config.py

@@ -41,6 +41,8 @@ def __init__(self):
         self.oval_unfixed_eval_enabled = strtobool(os.getenv("OVAL_UNFIXED_EVAL_ENABLED", "TRUE"))
         self.prometheus_multiproc_dir = os.getenv("PROMETHEUS_MULTIPROC_DIR", "/tmp/prometheus_multiproc_dir")
 
+        self.pg_max_stack_depth = os.getenv("PG_MAX_STACK_DEPTH", "")
+
 
 # pylint: disable=too-many-instance-attributes
 class Config(BaseConfig, metaclass=Singleton):

vmaas/reposcan/database/upgrade.py

@@ -63,6 +63,13 @@ def init_schema(self):
             self._get_db_lock(conn)
             LOGGER.info("Empty database, initializing...")
             with conn.cursor() as cur:
+                if cfg.pg_max_stack_depth:
+                    # vmaas.reposcan needs bigger max_stack_depth for ephemeral environment
+                    # increase max_stack_depth when the DB is empty (probably only in ephemeral env)
+                    cur.connection.autocommit = True  # autocommit to run queries without transaction
+                    cur.execute(f"ALTER SYSTEM SET max_stack_depth TO {cfg.pg_max_stack_depth}")
+                    cur.execute(f"ALTER DATABASE vmaas SET max_stack_depth TO {cfg.pg_max_stack_depth}")
+                    cur.connection.autocommit = False
                 with open(USER_CREATE_SQL_PATH, "r", encoding='utf8') as f_user, \
                         open(DB_CREATE_SQL_PATH, "r", encoding='utf8') as f_db:
                     cur.execute(f_user.read())