minor nits

Author: aniketsinghrawat

weather_mv/loader_pipeline/bq.py

@@ -135,7 +135,7 @@ def validate_arguments(cls, known_args: argparse.Namespace, pipeline_args: t.Lis
             # checking if the output table is in format (<project>.<dataset>.<table>).
             output_table_pattern = r'^[\w-]+\.[\w-]+\.[\w-]+$'
             if not bool(re.match(output_table_pattern, known_args.output_table)):
-                raise RuntimeError("output_table is not in correct format.")
+                raise RuntimeError("output_table is not in correct format (<project>.<dataset_id>.<table_id>). ")
 
         if known_args.area:
             assert len(known_args.area) == 4, 'Must specify exactly 4 lat/long values for area: N, W, S, E boundaries.'
@@ -168,8 +168,8 @@ def __post_init__(self):
 
     def create_bq_table(self, uri: str) -> str:
         """Create a big query table for the first uri. After table is created, subsequent uris are returned."""
+        # Skip table creation.
         if self.table:
-            # Skip table creation.
             return uri
 
         with open_dataset(uri, self.xarray_open_dataset_kwargs,

weather_mv/loader_pipeline/pipeline.py

@@ -47,7 +47,7 @@ def pattern_to_uris(match_pattern: str, is_zarr: bool = False) -> t.Iterable[str
 
 def pipeline(known_args: argparse.Namespace, pipeline_args: t.List[str]) -> None:
     all_uris = list(pattern_to_uris(known_args.uris, known_args.zarr))
-    if not all_uris and "topic" not in known_args:
+    if not all_uris and not known_args.topic:
         raise FileNotFoundError(f"File pattern '{known_args.uris}' matched no objects")
 
     # First URI is useful to get an example data shard. It also can be a Zarr path.