|
20 | 20 | import pytz |
21 | 21 | import structlog |
22 | 22 | from cachetools.func import ttl_cache |
| 23 | +from datacube.drivers.postgres._fields import PgDocField |
| 24 | +from datacube.index import Index |
| 25 | +from datacube.model import Dataset, MetadataType, Product, Range |
23 | 26 | from dateutil import tz |
24 | 27 | from eodatasets3.stac import MAPPING_EO3_TO_STAC |
25 | 28 | from geoalchemy2 import WKBElement |
26 | 29 | from geoalchemy2 import shape as geo_shape |
27 | 30 | from geoalchemy2.shape import from_shape, to_shape |
| 31 | +from odc.geo.geom import Geometry |
28 | 32 | from pygeofilter.backends.sqlalchemy.evaluate import ( |
29 | 33 | SQLAlchemyFilterEvaluator as FilterEvaluator, |
30 | 34 | ) |
|
43 | 47 | from sqlalchemy.dialects.postgresql import TSTZRANGE |
44 | 48 | from sqlalchemy.sql import Select |
45 | 49 |
|
46 | | -try: |
47 | | - from cubedash._version import version as explorer_version |
48 | | -except ModuleNotFoundError: |
49 | | - explorer_version = "ci-test-pipeline" |
50 | | -from datacube.drivers.postgres._fields import PgDocField |
51 | | -from datacube.index import Index |
52 | | -from datacube.model import Dataset, MetadataType, Product, Range |
53 | | -from odc.geo.geom import Geometry |
54 | | - |
55 | 50 | from cubedash import _utils |
56 | 51 | from cubedash.index import EmptyDbError, ExplorerIndex |
57 | 52 | from cubedash.index.postgis import ExplorerPgisIndex |
@@ -300,14 +295,12 @@ def is_schema_compatible(self, for_writing_operations_too: bool = False) -> bool |
300 | 295 | """ |
301 | 296 | Have all schema updates been applied? |
302 | 297 | """ |
| 298 | + from cubedash._version import __version__ |
| 299 | + |
303 | 300 | postgis_ver, is_compatible = self.e_index.schema_compatible_info( |
304 | 301 | for_writing_operations_too |
305 | 302 | ) |
306 | | - _LOG.debug( |
307 | | - "software.version", |
308 | | - postgis=postgis_ver, |
309 | | - explorer=explorer_version, |
310 | | - ) |
| 303 | + _LOG.debug("software.version", postgis=postgis_ver, explorer=__version__) |
311 | 304 | return is_compatible |
312 | 305 |
|
313 | 306 | def init(self, grouping_epsg_code: int | None = None) -> None: |
|
0 commit comments