25748807077

Committed 12 May 2026 04:46PM UTC coverage: 87.868% (-0.2%) from 88.052%

Build # 25748807077

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #1625 from sul-dlss/airflow3-upgrade

Airflow3 upgrade :tada:

Coverage Stats

247 of 329 new or added lines in 53 files covered. (75.08%)

7 existing lines in 6 files now uncovered.

5439 of 6190 relevant lines covered (87.87%)

0.88 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

54.55

/libsys_airflow/plugins/data_exports/sql_pool.py

from airflow.sdk import Connection, Variable
from psycopg2.pool import SimpleConnectionPool


class SQLPool:
    def __init__(self, conn_id, **kwargs):
        self.conn_id = conn_id
        self.conn = self.connection()

    def connection(self):
        return Connection.get(self.conn_id)

    def pool(self):
        conn = self.conn
        return SimpleConnectionPool(
            12,
            Variable.get('folio_sql_max_pool_size', 48),
            database='okapi',
            host=conn.host,
            password=conn.password,
            port=conn.port,
            user='okapi',
        )

1	from airflow.sdk import Connection, Variable	1✔
2	from psycopg2.pool import SimpleConnectionPool	1✔
3
4
5	class SQLPool:	1✔
6	def __init__(self, conn_id, **kwargs):	1✔
NEW 7	self.conn_id = conn_id	×
UNCOV 8	self.conn = self.connection()	×
9
10	def connection(self):	1✔
NEW 11	return Connection.get(self.conn_id)	×
12
13	def pool(self):	1✔
14	conn = self.conn	×
15	return SimpleConnectionPool(	×
16	12,
17	Variable.get('folio_sql_max_pool_size', 48),
18	database='okapi',
19	host=conn.host,
20	password=conn.password,
21	port=conn.port,
22	user='okapi',
23	)

sul-dlss / libsys-airflow / 25748807077

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous