diff --git a/schimpy/batch_metrics.py b/schimpy/batch_metrics.py
index efeace2..6a76f06 100644
--- a/schimpy/batch_metrics.py
+++ b/schimpy/batch_metrics.py
@@ -227,7 +227,7 @@ def retrieve_ts_obs(self, station_id, subloc, variable, window,
                         else:
                             raise Exception(
                             "Multiple column series received. Need to implement selector")
-                    ts_obs = ts_obs.squeeze()
+                    ts_obs = ts_obs[window[0]:window[1]].squeeze()
                 except ValueError as e:
                     raise
                     self.logger.warning(