fix: Exception raised with agenda push notifications

superdesk · Dec 16, 2024 · 174129f · 174129f
1 parent e9c4a1a
commit 174129f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/newsroom/agenda/agenda_service.py b/newsroom/agenda/agenda_service.py
@@ -383,7 +383,7 @@ def update_coverage_details(coverage: dict[str, Any]):
                 }
                 await self.system_update(item["_id"], updates)
 
-            updated_agenda = self.find_by_id(item["_id"])
+            updated_agenda = await self.find_by_id(item["_id"])
             # Notify agenda to update itself with new details of coverage
             parent_coverage["publish_time"] = wire_item.get("publish_schedule") or wire_item.get("firstpublished")
             await push_agenda_item_notification("new_item", item=item)

diff --git a/newsroom/commands/__init__.py b/newsroom/commands/__init__.py
@@ -25,5 +25,5 @@
 
 
 @celery.task(soft_time_limit=600)
-def async_remove_expired_agenda():
-    remove_expired_agenda()
+async def async_remove_expired_agenda():
+    await remove_expired_agenda()