diff --git a/SAS/DataManagement/StorageQueryService/cache.py b/SAS/DataManagement/StorageQueryService/cache.py
index c1b1cda8144c9839483539aa528d5b15b00a40ac..fe7626f7a9d8300e8cdc00bfac0527cfe83989e7 100644
--- a/SAS/DataManagement/StorageQueryService/cache.py
+++ b/SAS/DataManagement/StorageQueryService/cache.py
@@ -48,7 +48,7 @@ class CacheManager:
                                              numthreads=2)
 
         self.otdb_listener.onObservationAborted = self.onObservationAborted
-        self.otdb_listener.onObservationFinished = self.onObservationFinished
+        self.otdb_listener.onObservationCompleting = self.onObservationCompleting
 
         self.dm_listener = DataManagementBusListener(busname=dm_notification_busname,
                                                      subjects=dm_notification_prefix + '*',
@@ -322,7 +322,7 @@ class CacheManager:
     def __exit__(self, exc_type, exc_val, exc_tb):
         self.close()
 
-    def onObservationFinished(self, otdb_id, modificationTime):
+    def onObservationCompleting(self, otdb_id, modificationTime):
         self._onDiskActivityForOTDBId(otdb_id)
 
     def onObservationAborted(self, otdb_id, modificationTime):