feat: tag the release pipeline backfill in the sync log

Author: herzog0

libraries/management/commands/release_tasks.py

@@ -62,7 +62,10 @@ def set_tasks(self):
             Action("Updating website statistics", self.update_website_statistics),
             Action("Importing mailing list counts", self.import_ml_counts),
             # Last, so every source it reads has already been refreshed above.
-            Action("Backfilling achievements", ["backfill_achievements"]),
+            Action(
+                "Backfilling achievements",
+                ["backfill_achievements", "--trigger", "pipeline"],
+            ),
             # Action("Generating report", self.generate_report),
         ]
 

libraries/tasks.py

@@ -281,7 +281,7 @@ def update_authors_and_maintainers():
     call_command("update_library_version_authors", "--clean")
     app.signature("users.tasks.recompute_displayed_profile_roles").apply_async()
     # Only the sources whose upstream data just changed. A blanket backfill would
-    # also sweep the commit, review and news tables this task never touches.
+    # also sweep the commit and review tables this task never touches.
     call_command(
         "backfill_achievements",
         "--source",

libraries/tests/test_tasks.py

@@ -168,7 +168,7 @@ def test_update_library_version_website_adoc_no_stable_release():
 
 @patch("libraries.tasks.call_command")
 def test_update_authors_and_maintainers_backfills_only_library_sources(mock_call):
-    """A blanket backfill here would sweep the commit, review and news tables."""
+    """A blanket backfill here would sweep the commit and review tables too."""
     from libraries.tasks import update_authors_and_maintainers
 
     update_authors_and_maintainers()
@@ -208,8 +208,12 @@ def test_release_tasks_delegates_the_backfill_to_the_command(mock_call):
 
     assert [c.args[0] for c in mock_call.call_args_list] == ["release_tasks"]
     manager = ReleaseTasksManager(base_uri="https://example.com", user_id=None)
-    assert [
-        task.description
+    sweeps = [
+        task
         for task in manager.tasks
-        if task.handler == ["backfill_achievements"]
-    ] == ["Backfilling achievements"]
+        if isinstance(task.handler, list) and task.handler[0] == "backfill_achievements"
+    ]
+    assert [task.description for task in sweeps] == ["Backfilling achievements"]
+    # Tagged, so the sync log can tell the weekly job from a person pressing a
+    # button when support asks what moved a member's count.
+    assert sweeps[0].handler == ["backfill_achievements", "--trigger", "pipeline"]