Rename buckets to data-sets

migrations/008_convert_ga_data_sets_to_utc.py

@@ -12,7 +12,7 @@
 
 log = logging.getLogger(__name__)
 
-GA_BUCKETS_TO_MIGRATE = [
+GA_DATA_SETS_TO_MIGRATE = [
     "carers_allowance_journey",
     "deposit_foreign_marriage_journey",
     "pay_foreign_marriage_certificates_journey",
@@ -75,7 +75,7 @@ def data_id(data_type, timestamp, period):
 
 
 def up(db):
-    for name in GA_BUCKETS_TO_MIGRATE:
+    for name in GA_DATA_SETS_TO_MIGRATE:
         collection = db.get_repository(name)
 
         documents = collection.find({})

migrations/009_fix_and_resize_capped_collections.py

@@ -1,7 +1,7 @@
 """
 Clean up capped collections:
 
-- Update realtime buckets to be capped at 4mb (4194304b), which gives us
+- Update realtime data-sets to be capped at 4mb (4194304b), which gives us
   about 2 weeks worth of query depth with a few days tolerance.
 - Copy any non realtime collections that are capped into uncapped collections
 
@@ -98,7 +98,7 @@ def remove_temporary_collections(mongo_db):
         mongo_db[collection_name].drop()
 
 
-def realtime_bucket_is_correctly_capped(mongo_db, collection_name):
+def realtime_data_set_is_correctly_capped(mongo_db, collection_name):
     stats = mongo_db[collection_name].options()
     return stats.get('capped') is True and stats['size'] == CAP_SIZE
 
@@ -110,7 +110,7 @@ def up(db):
 
     # Correctly cap all realtime collections
     for collection_name in get_realtime_collection_names(mongo_db):
-        if realtime_bucket_is_correctly_capped(mongo_db, collection_name):
+        if realtime_data_set_is_correctly_capped(mongo_db, collection_name):
             log.info("Skipping {0}, already correctly capped".format(
                 collection_name))
             continue