diff --git a/podaac/merger/harmony/service.py b/podaac/merger/harmony/service.py index 9dfe110f..2e1e981e 100644 --- a/podaac/merger/harmony/service.py +++ b/podaac/merger/harmony/service.py @@ -66,6 +66,9 @@ def process_catalog(self, catalog: Catalog): if len(items) == 0: return result + # # --- Get granule filepaths (urls) --- + netcdf_urls: list[str] = _get_netcdf_urls(items) + # -- Process metadata -- bbox = [] granule_urls = [] @@ -85,7 +88,11 @@ def process_catalog(self, catalog: Catalog): # -- Perform merging -- collection = self._get_item_source(items[0]).collection - filename = f'{collection}_merged.nc4' + first_granule_url = [] + get_granule_url(items[0], first_granule_url) + first_url_name = Path(first_granule_url[0]).stem + f'{first_url_name}_{datetimes[1].isoformat()}_{collection}_merged.nc4' + filename = f'{collection}_{datetimes[0].isoformat()}-{datetimes[1].isoformat()}_merged.nc4' with TemporaryDirectory() as temp_dir: self.logger.info('Starting granule downloads')