File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
services/notifications/src/simcore_service_notifications/services Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 11import logging
22
33from models_library .rpc .notifications import Notification
4- from servicelib .celery .models import TaskContext
4+ from servicelib .celery .models import TaskFilter
55from servicelib .celery .task_manager import TaskManager
66
77from ..modules .celery .tasks import TaskQueue
@@ -16,8 +16,8 @@ async def send_notification(
1616) -> None :
1717 await task_manager .send_task (
1818 # send to the specific channel worker
19- name = f"notifications.{ notification .channel .type } " ,
20- context = TaskContext (), # TODO: TaskFilter
19+ task_name = f"notifications.{ notification .channel .type } " ,
20+ task_filter = TaskFilter (), # TODO: TaskFilter
2121 task_queue = TaskQueue .DEFAULT ,
2222 notification = notification ,
2323 )
You can’t perform that action at this time.
0 commit comments