chore: fix lint issues

openedx/core/djangoapps/content_libraries/management/commands/recreate_upstream_links.py

@@ -62,7 +62,7 @@ def handle(self, *args, **options):
         courses = options['course']
         should_process_all = options['all']
         force = options['force']
-        self.time_now = datetime.now(tz=timezone.utc)
+        time_now = datetime.now(tz=timezone.utc)
         if not courses and not should_process_all:
             raise CommandError('Either --course or --all argument should be provided.')
 
@@ -73,4 +73,4 @@ def handle(self, *args, **options):
             courses = CourseOverview.get_all_course_keys()
         for course in courses:
             log.info(f"Start processing upstream->dowstream links in course: {course}")
-            create_or_update_upstream_links.delay(str(course), force)
+            create_or_update_upstream_links.delay(str(course), force, created=time_now)

openedx/core/djangoapps/content_libraries/tasks.py

@@ -177,6 +177,9 @@ def duplicate_children(
 @shared_task(base=LoggedTask)
 @set_code_owner_attribute
 def create_or_update_xblock_upstream_link(usage_key):
+    """
+    Create or update upstream link for a single xblock.
+    """
     ensure_cms("create_or_update_xblock_upstream_link may only be executed in a CMS context")
     xblock = modulestore().get_item(UsageKey.from_string(usage_key))
     if not xblock.upstream:
@@ -192,13 +195,14 @@ def create_or_update_xblock_upstream_link(usage_key):
 
 @shared_task(base=LoggedTask)
 @set_code_owner_attribute
-def create_or_update_upstream_links(course_key_str: str, force: bool = False):
+def create_or_update_upstream_links(course_key_str: str, force: bool = False, created: datetime | None = None):
     """
     A Celery task to create or update upstream downstream links in database from course xblock content.
     """
     ensure_cms("create_or_update_upstream_links may only be executed in a CMS context")
 
-    created = datetime.now(timezone.utc)
+    if not created:
+        created = datetime.now(timezone.utc)
     course_status = get_or_create_course_link_status(course_key_str, created)
     if course_status.status in [
         CourseLinksStatusChoices.COMPLETED,

openedx/core/djangoapps/content_libraries/tests/test_upstream_downstream_links.py

@@ -42,7 +42,7 @@ def test_call_with_invalid_args(self):
             self.call_command('--all', '--course', 'some-course')
 
     @patch(
-        'openedx.core.djangoapps.content_libraries.management.commands.recreate_upstream_links.create_or_update_upstream_links'
+        'openedx.core.djangoapps.content_libraries.management.commands.recreate_upstream_links.create_or_update_upstream_links'  # pylint: disable=line-too-long
     )
     def test_call_for_single_course(self, mock_task):
         """
@@ -55,7 +55,7 @@ def test_call_for_single_course(self, mock_task):
         mock_task.delay.assert_called_with('some-course', True)
 
     @patch(
-        'openedx.core.djangoapps.content_libraries.management.commands.recreate_upstream_links.create_or_update_upstream_links'
+        'openedx.core.djangoapps.content_libraries.management.commands.recreate_upstream_links.create_or_update_upstream_links'  # pylint: disable=line-too-long
     )
     def test_call_for_multiple_course(self, mock_task):
         """
@@ -66,7 +66,7 @@ def test_call_for_multiple_course(self, mock_task):
         mock_task.delay.assert_any_call('one-more-course', False)
 
     @patch(
-        'openedx.core.djangoapps.content_libraries.management.commands.recreate_upstream_links.create_or_update_upstream_links'
+        'openedx.core.djangoapps.content_libraries.management.commands.recreate_upstream_links.create_or_update_upstream_links'  # pylint: disable=line-too-long
     )
     def test_call_for_all_courses(self, mock_task):
         """