Merge pull request #86 from CDCgov/rr-85-fail-fast

Rr 85 fail fast

Author: ryanraaschCDC

README.md

@@ -41,7 +41,6 @@ Read the [Dataset Developer Guide](docs/data_developer_guide.md) for information
 ## Project admins
 
 - Thomas Hladish <utx5@cdc.gov> (CDC/OD/ORR/CFA)
-- Phillip Rogers <ap66@cdc.gov> (CDC/OD/ORR/CFA)(CTR)
 - Ryan Raasch <xng3@cdc.gov> (CDC/OD/ORR/CFA)(CTR)
 
 ---

cfa/dataops/__init__.py

@@ -12,6 +12,8 @@
 except ImportError:
     __version__ = "unknown"
 
+from .catalog import datacat, reportcat
+
 __all__ = ["__version__", "datacat", "reportcat"]
 
 

cfa/dataops/catalog.py

@@ -20,6 +20,7 @@
     walk_blobs_in_container,
     write_blob_stream,
 )
+from cfa.cloudops.util import check_ext_env
 
 from .config_validator import (
     ConfigValidator,
@@ -266,6 +267,8 @@ def get_versions(self) -> list:
             list: sorted list of data version paths in descending order
             (latest first)
         """
+        if not check_ext_env():
+            raise RuntimeError("No EXT access configured.")
         glob_path = f"{self.prefix}/"
         return sorted(
             [
@@ -321,6 +324,9 @@ def _get_version_blobs(
         Raises:
             ValueError: If the requested version cannot be resolved.
         """
+        # check credential access
+        if not check_ext_env():
+            raise RuntimeError("No EXT access configured.")
         if not self.is_ledger:
             available_versions = self.get_versions()
             version = version_matcher(
@@ -454,6 +460,8 @@ def get_dataframe(
         Returns:
             pd.DataFrame | pl.DataFrame | pl.LazyFrame: the dataframe
         """
+        if not check_ext_env():
+            raise RuntimeError("No EXT access configured.")
         if output not in ["pandas", "polars", "pd", "pl", "pl_lazy", "lazy"]:
             raise ValueError(
                 f"Output {output} needs to be 'pandas', 'polars', 'pd', 'pl', 'pl_lazy', or 'lazy'."

changelog.md

@@ -7,6 +7,12 @@ and this project adheres to [Calendar Versioning](https://calver.org/).
 The versioning pattern is `YYYY.MM.DD.micro(a/b/{none if release})
 
 ---
+## [2026.05.29.1]
+
+### Fixed
+
+- added a check to ensure the right environment, otherwise the code fails faster
+
 ## [2026.05.29.0]
 
 ### Fixed

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "cfa.dataops"
-version = "2026.05.29.0"
+version = "2026.05.29.1"
 description = "Data cataloging, ETL, modeling, verification, and validation for CFA"
 authors = [
     { name = "Phil Rogers", email = "ap66@cdc.gov" },

tests/conftest.py

@@ -26,6 +26,10 @@ def __getattr__(self, name):
 
 
 def _install_test_stubs() -> None:
+    _ensure_module(
+        "cfa.cloudops.util",
+        check_ext_env=lambda *args, **kwargs: True,
+    )
     _ensure_module(
         "cfa.cloudops.blob_helpers",
         read_blob_stream=lambda *args, **kwargs: b"",
@@ -34,6 +38,7 @@ def _install_test_stubs() -> None:
     )
     _ensure_module("cfa.cloudops")
     sys.modules["cfa.cloudops"].blob_helpers = sys.modules["cfa.cloudops.blob_helpers"]
+    sys.modules["cfa.cloudops"].util = sys.modules["cfa.cloudops.util"]
 
     _ensure_module(
         "azure.identity",