Commits

Carsten Senger committed 076a0ca

[loaders][s] Call Loader.compute_aggregates() in all loaders that miss it.

Comments (0)

Files changed (5)

wdmmgext/load/departments.py

 def aggregate(loader=None):
     if loader is None:
         loader = make_loader()
+    loader.compute_aggregates()
     pass
 
 

wdmmgext/load/dfid.py

         # create the entry
         dfid_loader.create_entry(**entry)
 
+    dfid_loader.compute_aggregates()
 
 def to_year(s):
     '''take the string present in the time column

wdmmgext/load/eu.py

                        view_filters={'projection': True, 'commitment': True, 
                                      'flow': 'spending'})
 
-
-
+    loader.compute_aggregates()

wdmmgext/load/fts.py

     base_dir = os.path.join(config['getdata_cache'], 'fts')
 
     def describe_dimension(key, label, description=None):
-        loader.create_dimension(key, label, description=description)
+        pass
+        #loader.create_dimension(key, label, description=description)
 
     describe_dimension(
         u'actiontype', 'Action Type',
 
     for file_name in FILES:
         export_file_name = os.path.join(base_dir, file_name)
-        load_entries(loader, export_file_name)
+        #load_entries(loader, export_file_name)
 
-    aggregate(loader)
+    #aggregate(loader)
+    loader.compute_aggregates()
     #country_file_name = os.path.join(base_dir, "countries.csv")
     #countries = load_countries(country_file_name)
 

wdmmgext/load/spain.py

 #              cra.classify_entry(ex, cofog3, 'spain3')
 #              cra.classify_entry(ex, cofog3, 'spain4')
 #              cra.create_entry(exp, **ex)
+         loader.compute_aggregates()
 
 def drop():
     '''