logging

Author: asadali145

src/ol_openedx_course_sync/signals.py

@@ -27,16 +27,21 @@ def listen_for_course_publish(
         return
 
     course_sync_map = CourseSyncMap.objects.filter(source_course=course_key).first()
-    if course_sync_map and course_sync_map.target_courses:
-        source_course = str(course_sync_map.source_course)
-        user_id = 2
-        for target_course_key in course_sync_map.target_courses.split(","):
-            # Call the async task to copy the course content
-            async_course_sync.delay(user_id, source_course, target_course_key)
-    else:
-        log.warning("No mapping found for course %s. Skipping copy.", course_key.id)
+    if not (course_sync_map and course_sync_map.target_courses):
+        log.info("No mapping found for course %s. Skipping copy.", course_key.id)
         return
 
+    source_course = str(course_sync_map.source_course)
+    user_id = 2
+    for target_course_key in course_sync_map.target_courses.split(","):
+        log.info(
+            "Initializing async course content sync from %s to %s",
+            source_course,
+            target_course_key,
+        )
+        # Call the async task to copy the course content
+        async_course_sync.delay(user_id, source_course, target_course_key)
+
 
 @receiver(post_save, sender=CourseRerunState)
 def listen_for_course_rerun_state_post_save(sender, instance, **kwargs):  # noqa: ARG001
@@ -55,6 +60,10 @@ def listen_for_course_rerun_state_post_save(sender, instance, **kwargs):  # noqa
     if CourseSyncMap.objects.filter(
         target_courses__contains=str(instance.source_course_key)
     ).exists():
+        log.warning(
+            "Course %s is already a target course. Skipping.",
+            instance.source_course_key,
+        )
         return
 
     course_sync_map, _ = CourseSyncMap.objects.get_or_create(
@@ -68,3 +77,8 @@ def listen_for_course_rerun_state_post_save(sender, instance, **kwargs):  # noqa
     target_courses.append(str(instance.course_key))
     course_sync_map.target_courses = ",".join(target_courses)
     course_sync_map.save()
+    log.info(
+        "Added course %s to target courses for %s",
+        instance.course_key,
+        instance.source_course_key,
+    )