run query to update groups completed count and update only groups which changed

Author: Herfort

mapswipe_workers/basic/BaseProject.py

@@ -164,10 +164,10 @@ def set_groups_progress_postgres(self, postgres, groups_progress_list):
 
         p_con = postgres()
 
-        groups_progress_tablename = 'groups_progress'
+        # groups_progress_tablename = 'groups_progress'
         groups_progress_columns = ('project_id', 'group_id', 'completedcount')
         sql_insert = '''
-                    DROP TABLE IF EXISTS {};
+                    DROP TABLE IF EXISTS ;
                     CREATE TABLE {} (
                         project_id int
                         ,group_id int
@@ -193,6 +193,8 @@ def set_groups_progress_postgres(self, postgres, groups_progress_list):
         sql_insert = sql.SQL(sql_insert).format(sql.Identifier(groups_progress_tablename),
                                                 sql.Identifier(groups_progress_tablename))
 
+        p_con.query(sql_insert, None)
+
         del p_con
         logging.warning('%s - set_groups_progress_postgres - finished setting groups progress in postgres' % self.id)