(name: str)
| 64 | |
| 65 | |
| 66 | def _require_env(name: str) -> str: |
| 67 | value = os.environ.get(name) |
| 68 | if not value: |
| 69 | raise RuntimeError( |
| 70 | f"{name} is not set. This test requires real GCP credentials; " |
| 71 | "see the docstring at the top of mzcompose.py." |
| 72 | ) |
| 73 | return value |
| 74 | |
| 75 | |
| 76 | def _read_gcs_avro(gs_url: str, token: str, project: str) -> list[Any]: |