chore: ⚙️ version bump in code

* fix: 🐞 Fixed an ordering issue when saving to CSV

* chore: 🧹 Ruff clean up

main.py

@@ -100,7 +100,9 @@ if __name__ == "__main__":
             logging.info("Aborting...")
             exit(0)
         else:
-            shutil.rmtree(Path(Config.COMBINED_FOLDER))  # Delete everything including the directory
+            shutil.rmtree(
+                Path(Config.COMBINED_FOLDER)
+            )  # Delete everything including the directory
             Path(Config.COMBINED_FOLDER).mkdir()
 
     extraction = Extract(Config)
@@ -168,7 +170,7 @@ if __name__ == "__main__":
                         files_processed_so_far = (
                             files_processed_previous + completed_count
                         )
-                        
+
                         elapsed_time = time.time() - start
                         rate_per_second = files_processed_so_far / elapsed_time
 
@@ -215,6 +217,8 @@ if __name__ == "__main__":
     elif elapsed_time < 3600:
         elapsed_time_str = f"{int(elapsed_time // 60)}m {int(elapsed_time % 60)}s"
     else:
-        elapsed_time_str = f"{int(elapsed_time // 3600)}h {int((elapsed_time % 3600) // 60)}m"
+        elapsed_time_str = (
+            f"{int(elapsed_time // 3600)}h {int((elapsed_time % 3600) // 60)}m"
+        )
 
     logging.info(f"All Complete total time {elapsed_time_str}")

modules/generate_timeseries.py

@@ -56,11 +56,11 @@ class GenerateTimeseries:
         xpp = ncols_basin * cellres_basin
         ypp = nrows_basin * cellres_basin
 
-        start_col = np.floor(xp / cellres_radar)
+        start_col = np.floor(xp / cellres_radar) - 1
-        end_col = np.ceil((xpp + xp) / cellres_radar)
+        end_col = np.ceil((xpp + xp) / cellres_radar) - 1
 
-        start_row = np.floor(nrows_radar - ((yp + ypp) / cellres_radar))
+        start_row = np.floor(nrows_radar - ((yp + ypp) / cellres_radar)) + 1
-        end_row = np.ceil(nrows_radar - (yp / cellres_radar))
+        end_row = np.ceil(nrows_radar - (yp / cellres_radar)) + 1
 
         return int(start_col), int(start_row), int(end_col), int(end_row)
 
@@ -178,43 +178,26 @@ class GenerateTimeseries:
             zone_name = loc[3]
 
             if zone_name not in zone_data:
-                zone_data[zone_name] = {"dates": [], "values": {}}
+                zone_data[zone_name] = {"dates": set(), "values": {}}
 
-            zone_data[zone_name]["values"][zone_id] = results[zone_id]["values"]
+            # Create date -> value map for this grid square
-            zone_data[zone_name]["dates"].extend(results[zone_id]["dates"])
+            raw_dates = results[zone_id]["dates"]
+            raw_values = results[zone_id]["values"]
+            date_value_map = dict(zip(raw_dates, raw_values))
 
-        # Get unique sorted dates across all zones
+            zone_data[zone_name]["values"][zone_id] = date_value_map
-        for zone_name, data in zone_data.items():
+            zone_data[zone_name]["dates"].update(raw_dates)
-            data["dates"] = sorted(set(data["dates"]))
 
         # Now write one CSV per zone with aligned timestamps
         for zone_name, data in zone_data.items():
-            dates = data["dates"]
+            sorted_dates = sorted(data["dates"])
             values_dict = data["values"]
 
             # Create aligned DataFrame
-            df_dict = {"datetime": dates}
+            df_dict = {"datetime": sorted_dates}
-            for grid_square, values in values_dict.items():
+            for grid_square, dv_map in values_dict.items():
-                # Align values to the common dates
+                # Align values to the common search dates using the map
-                aligned_values = []
+                aligned_values = [dv_map.get(d) for d in sorted_dates]
-                value_iter = iter(values)
-                date_iter = iter(dates)
-
-                current_date = next(date_iter, None)
-                current_value = next(value_iter, None)
-
-                for expected_date in dates:
-                    if current_date == expected_date:
-                        aligned_values.append(current_value)
-                        try:
-                            current_date = next(date_iter)
-                            current_value = next(value_iter)
-                        except StopIteration:
-                            current_date = None
-                            current_value = None
-                    else:
-                        aligned_values.append(None)  # Missing value
-
                 df_dict[grid_square] = aligned_values
 
             new_df = pd.DataFrame(df_dict)

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "met-office"
-version = "1.3.2"
+version = "1.3.3"
 description = "Convert nimrod files to .csv timeseries"
 readme = "README.md"
 requires-python = ">=3.14"

uv.lock

@@ -4,7 +4,7 @@ requires-python = ">=3.14"
 
 [[package]]
 name = "met-office"
-version = "1.3.2"
+version = "1.3.3"
 source = { virtual = "." }
 dependencies = [
     { name = "numpy" },