debug

course_discovery/apps/publisher/dataloader/create_courses.py

@@ -6,6 +6,7 @@ from django.core.files import File
 
 from course_discovery.apps.publisher.choices import CourseRunStateChoices, CourseStateChoices, PublisherUserRole
 from course_discovery.apps.publisher.models import Course, CourseRun, CourseRunState, CourseState, Seat
+from course_discovery.apps.publisher.signals import PUBLISHER_COURSE_RUN_CREATED
 
 logger = logging.getLogger(__name__)
 
@@ -142,6 +143,11 @@ def create_course_runs(meta_data_course, publisher_course):
 
             # Initialize workflow for Course-run.
             if created:
+                PUBLISHER_COURSE_RUN_CREATED.send(
+                    model=publisher_course_run,
+                    start=canonical_course_run.start,
+                    end=canonical_course_run.end
+                )
                 state, created = CourseRunState.objects.get_or_create(course_run=publisher_course_run)
                 if created:
                     state.approved_by_role = PublisherUserRole.ProjectCoordinator

course_discovery/apps/publisher/signals.py

@@ -4,7 +4,7 @@ import waffle
 from django.contrib.auth.models import Permission
 from django.core.exceptions import ObjectDoesNotExist
 from django.db.models.signals import post_save
-from django.dispatch import receiver
+from django.dispatch import receiver, Signal
 from slumber.exceptions import SlumberBaseException
 
 from course_discovery.apps.publisher.models import CourseRun, OrganizationExtension
@@ -12,6 +12,7 @@ from course_discovery.apps.publisher.studio_api_utils import StudioAPI
 
 logger = logging.getLogger(__name__)
 
+PUBLISHER_COURSE_RUN_CREATED = Signal(providing_args=['model', 'start', 'end'])
 
 def get_related_discovery_course_run(publisher_course_run):
     try:
@@ -21,7 +22,7 @@ def get_related_discovery_course_run(publisher_course_run):
         return
 
 
-@receiver(post_save, sender=CourseRun)
+@receiver(PUBLISHER_COURSE_RUN_CREATED, sender=CourseRun)
 def create_course_run_in_studio_receiver(sender, instance, created, **kwargs):  # pylint: disable=unused-argument
     if created and waffle.switch_is_active('enable_publisher_create_course_run_in_studio'):
         course = instance.course