Removed redundant logs in Python worker

backend/src/serverless/microservices/python/crowd-backend/crowd/backend/controllers/members_controller.py

@@ -37,8 +37,6 @@ def update(self, updates, send=True):
         Args:
             updates ([{id, update}]): list of dicts with id and corresponding update
         """
-        logger.info("UPDATES")
-        logger.info(updates)
         if type(updates) is not list:
             updates = [
                 updates,

backend/src/serverless/microservices/python/crowd-backend/crowd/backend/utils/grid/grid.py

@@ -26,5 +26,4 @@ class GithubGrid(BaseGrid):
     unstar = -2
     fork = 4
 
-if __name__ == "__main__":
-    logger.info(GithubGrid.get_score("issues-opened"))
+

backend/src/serverless/microservices/python/crowd-check-merge-members/crowd/check_merge_members/merge_suggestions.py

@@ -38,7 +38,6 @@ def __init__(self, tenant_id, sqs_sender, repository=False, test=False):
 
         # Compute all members
         self.comparison = self.repository.find_all_usernames()
-        logger.info(f"Found {len(self.comparison)} members to compare")
 
         self.test = test
 
@@ -58,7 +57,6 @@ def run(self, member_to_check_id):
             attempts += 1
 
         if not member_to_check:
-            logger.info("Member to check not found")
             return
 
         # Check if tenant has only 1 integration

backend/src/serverless/microservices/python/crowd-check-merge-members/crowd/check_merge_members/merge_suggestions_simple.py

@@ -45,7 +45,6 @@ def update_members_to_merge(self, arr_of_merge_members):
         """
         # Replacing  each Member with its respective id
         out = [(str(ms[0].id), str(ms[1].id)) for ms in arr_of_merge_members if ms[0].id != ms[1].id]
-        logger.info(f"Adding members to merge: {out}")
         if not self.test:
             MembersController(self.tenant_id, repository=self.repository).update_members_to_merge(out)
         return out

backend/src/serverless/microservices/python/crowd-members-score/crowd/members_score/members_score.py

@@ -18,7 +18,6 @@ class MembersScore:
     def __init__(self, tenant_id, repository=False, test=False, send=True):
 
         self.tenant_id = tenant_id
-        logger.info(tenant_id)
 
         if not repository:
             self.repository = Repository(tenant_id=self.tenant_id, test=test)
@@ -206,37 +205,25 @@ def normalise(self, scores):
     def main(self):
         # Keeping track of time for lambda timeout
         start = time.time()
-        logger.info("Finding members...")
         members = self.repository.find_all(Member, query={})
-        logger.info("Found all members")
 
-        logger.info("Saving original scores...")
         for member in members:
             self.original_scores[member.id] = member.score
-        logger.info("Done")
 
-        logger.info("Calculating member raw scores...")
         self.scores = self._member_scores_(members)
-        logger.info("Done")
 
         # Take care of case where tenant doesn't have activities
         if len(self.scores) == 0:
             return {}
 
-        logger.info("Normalising scores...")
         scores_to_update = self.normalise(self.scores)
-        logger.info("Done")
 
-        length = len(scores_to_update)
         changed = 0
 
         members_controller = MembersController(self.tenant_id, repository=self.repository)
 
         for n, member_id in enumerate(scores_to_update):
-            if n % 500 == 0:
-                logger.info(f"Updating {n} / {length}")
             if time.time() - start > 800:
-                logger.info("Time limit reached. Will continue next time")
                 break
             # We only update the score if it has changed
             if scores_to_update[member_id] != self.original_scores.get(member_id, -2):