def verify_alloydb_table()

in components/specialized-parser/src/runner.py [0:0]

• 13 lines of code
• 1 McCabe index (conditional complexity)

    def verify_alloydb_table(self) -> None:
        """
        Verify AlloyDB table exists to save results from the processor.
        """
        with self.alloydb_connection_pool.connect() as db_conn:
            db_conn.execute(
                sqlalchemy.text(
                    f"""
                CREATE TABLE IF NOT EXISTS {PROCESSED_DOCUMENTS_TABLE_NAME} (
                    id VARCHAR (255) NOT NULL PRIMARY KEY,
                    original_filename VARCHAR (2048) NOT NULL,
                    results_file VARCHAR (2048) NOT NULL,
                    run_id VARCHAR (255) NULL,
                    entities JSONB NULL
                );"""
                )
            )
            db_conn.execute(
                sqlalchemy.text(
                    f"ALTER TABLE {PROCESSED_DOCUMENTS_TABLE_NAME} OWNER TO eks_users;"
                )
            )
            db_conn.close()