[activity pull][xs]: stop fetching when filtered activities are less than returned ones as it means that all required activities are in the response.

Author: anuveyatsu

data_subscriptions/worker/latest_ckan_activity.py

@@ -50,6 +50,10 @@ def has_reached_the_end(self, last_response):
         if items_returned == 0:
             return True
 
+        items_after_filter = self.filter_response_for_time_range(last_response)
+        if len(list(items_after_filter)) < items_returned:
+            return True
+
         return (self.current_offset > 0) and (
             (items_returned < self.server_limit) or (len(self.activity_list) == 0)
         )