File tree Expand file tree Collapse file tree 2 files changed +6
-4
lines changed
services/notifications/src/simcore_service_notifications Expand file tree Collapse file tree 2 files changed +6
-4
lines changed Original file line number Diff line number Diff line change @@ -14,6 +14,8 @@ async def send_notification_message(
1414 message : NotificationMessage ,
1515 recipients : list [Recipient ],
1616) -> None :
17- await notifications_service .send_notification (
18- task_manager , message = message , recipients = recipients
17+ await notifications_service .send_notification_message (
18+ task_manager ,
19+ message = message ,
20+ recipients = recipients ,
1921 )
Original file line number Diff line number Diff line change 99_logger = logging .getLogger (__name__ )
1010
1111
12- async def send_notification (
12+ async def send_notification_message (
1313 task_manager : TaskManager ,
1414 * ,
1515 message : NotificationMessage ,
@@ -18,7 +18,7 @@ async def send_notification(
1818 for recipient in recipients :
1919 await task_manager .send_task (
2020 name = f"notifications.{ recipient .type } " ,
21- context = TaskContext (),
21+ context = TaskContext (), # TODO: TaskFilter
2222 queue = TaskQueue .DEFAULT ,
2323 message = message ,
2424 recipient = recipient ,
You can’t perform that action at this time.
0 commit comments