fix(provider): honour driver_name when a connection string omits the DBAPI

pygeoapi/api/tiles.py

@@ -389,7 +389,8 @@ def tilematrixsets(api: API,
     }]
 
     if request.format == F_HTML:  # render
-        content = render_j2_template(api.tpl_config, api.tpl_config,
+        content = render_j2_template(api.tpl_config,
+                                     api.config['server']['templates'],
                                      'tilematrixsets/index.html',
                                      tms, request.locale)
         return headers, HTTPStatus.OK, content
@@ -436,7 +437,8 @@ def tilematrixset(api: API,
     }
 
     if request.format == F_HTML:  # render
-        content = render_j2_template(api.tpl_config, api.tpl_config,
+        content = render_j2_template(api.tpl_config,
+                                     api.config['server']['templates'],
                                      'tilematrixsets/tilematrixset.html',
                                      tms, request.locale)
         return headers, HTTPStatus.OK, content

pygeoapi/process/manager/mongodb_.py

@@ -79,9 +79,15 @@ def get_jobs(self, status=None, limit=None, offset=None):
             database = self.db.job_manager_pygeoapi
             collection = database.jobs
             if status is not None:
-                jobs = list(collection.find({}, {"status": status}))
+                query = {"status": status}
             else:
-                jobs = list(collection.find({}))
+                query = {}
+            cursor = collection.find(query)
+            if offset:
+                cursor = cursor.skip(offset)
+            if limit:
+                cursor = cursor.limit(limit)
+            jobs = list(cursor)
             LOGGER.info("JOBMANAGER - MongoDB jobs queried")
             return {
                 'jobs': jobs,

pygeoapi/process/manager/postgresql.py

@@ -133,6 +133,11 @@ def get_jobs(
             if status is not None:
                 results = results.filter(self.c.status == status.value)
 
+            if offset:
+                results = results.offset(offset)
+            if limit:
+                results = results.limit(limit)
+
             jobs = [r._asdict() for r in results.all()]
             return {'jobs': jobs, 'numberMatched': len(jobs)}
 

pygeoapi/provider/sql.py

@@ -44,7 +44,7 @@
 from decimal import Decimal
 import functools
 import logging
-from typing import Optional, Any
+from typing import Optional, Any, Union
 
 from geoalchemy2 import Geometry  # noqa - this isn't used explicitly but is needed to process Geometry columns
 from geoalchemy2.functions import ST_MakeEnvelope, ST_Intersects
@@ -60,7 +60,7 @@
     desc,
     delete
 )
-from sqlalchemy.engine import URL, Engine
+from sqlalchemy.engine import URL, Engine, make_url
 from sqlalchemy.exc import (
     ConstraintColumnNotFoundError,
     InvalidRequestError,
@@ -649,7 +649,7 @@ def get_engine(
     database: str,
     user: str,
     password: str,
-    conn_str: Optional[str] = None,
+    conn_str: Optional[Union[str, URL]] = None,
     **connect_args
 ) -> Engine:
     """
@@ -679,6 +679,18 @@ def get_engine(
             port=int(port),
             database=database
         )
+    else:
+        # A caller-provided URL with a bare driver name (e.g. "postgresql://")
+        # resolves to SQLAlchemy's default DBAPI for that backend (psycopg v3
+        # for PostgreSQL), which may not be installed. Honour the provider's
+        # driver_name when the URL does not already pin one.
+        parsed = make_url(conn_str)
+        if '+' not in parsed.drivername and '+' in driver_name:
+            backend = driver_name.split('+', 1)[0]
+            if parsed.drivername == backend:
+                conn_str = parsed.set(
+                    drivername=driver_name
+                )
 
     # Separate connection-pool tuning from DBAPI connect args. Pool keys are
     # applied to create_engine() directly; everything left in connect_args is