diff --git a/dags/analyzer_helper/discourse/transform_raw_members.py b/dags/analyzer_helper/discourse/transform_raw_members.py index 9a5d6398..f1bff0b5 100644 --- a/dags/analyzer_helper/discourse/transform_raw_members.py +++ b/dags/analyzer_helper/discourse/transform_raw_members.py @@ -19,10 +19,12 @@ def transform(self, raw_members: list) -> list: """ transformed_members = [] - for member in raw_members: + for idx, member in enumerate(raw_members): try: transformed_member = self.transform_member(member=member) transformed_members.append(transformed_member) + + logging.info(f"Preparing raw members: {idx + 1}/{len(raw_members)}") except Exception as e: logging.error(f"Error transforming raw discourse member {member}: {e}")