diff --git a/backend/src/serverless/microservices/python/crowd-backend/crowd/backend/controllers/members_controller.py b/backend/src/serverless/microservices/python/crowd-backend/crowd/backend/controllers/members_controller.py index 6b081b338c..9b01df06b5 100644 --- a/backend/src/serverless/microservices/python/crowd-backend/crowd/backend/controllers/members_controller.py +++ b/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, diff --git a/backend/src/serverless/microservices/python/crowd-backend/crowd/backend/utils/grid/grid.py b/backend/src/serverless/microservices/python/crowd-backend/crowd/backend/utils/grid/grid.py index bcb2ed9efd..7b1bf028e6 100644 --- a/backend/src/serverless/microservices/python/crowd-backend/crowd/backend/utils/grid/grid.py +++ b/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")) + diff --git a/backend/src/serverless/microservices/python/crowd-check-merge-members/crowd/check_merge_members/merge_suggestions.py b/backend/src/serverless/microservices/python/crowd-check-merge-members/crowd/check_merge_members/merge_suggestions.py index c704ed4f87..69ea5a40f3 100644 --- a/backend/src/serverless/microservices/python/crowd-check-merge-members/crowd/check_merge_members/merge_suggestions.py +++ b/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 diff --git a/backend/src/serverless/microservices/python/crowd-check-merge-members/crowd/check_merge_members/merge_suggestions_simple.py b/backend/src/serverless/microservices/python/crowd-check-merge-members/crowd/check_merge_members/merge_suggestions_simple.py index 50ca42ac75..1907176ea6 100644 --- a/backend/src/serverless/microservices/python/crowd-check-merge-members/crowd/check_merge_members/merge_suggestions_simple.py +++ b/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 diff --git a/backend/src/serverless/microservices/python/crowd-members-score/crowd/members_score/members_score.py b/backend/src/serverless/microservices/python/crowd-members-score/crowd/members_score/members_score.py index 179d6b9279..ebd116ef9d 100644 --- a/backend/src/serverless/microservices/python/crowd-members-score/crowd/members_score/members_score.py +++ b/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):