diff --git a/shared/celery_config.py b/shared/celery_config.py
index ef714fd07..141a74540 100644
--- a/shared/celery_config.py
+++ b/shared/celery_config.py
@@ -22,6 +22,7 @@
     f"app.tasks.{TaskConfigGroup.sync_account.value}.ActivateAccountUser"
 )
 notify_task_name = f"app.tasks.{TaskConfigGroup.notify.value}.Notify"
+notification_orchestrator_task_name = f"app.tasks.{TaskConfigGroup.notification_orchestrator.value}.NotificationOrchestrator"
 pulls_task_name = f"app.tasks.{TaskConfigGroup.pulls.value}.Sync"
 status_set_error_task_name = f"app.tasks.{TaskConfigGroup.status.value}.SetError"
 status_set_pending_task_name = f"app.tasks.{TaskConfigGroup.status.value}.SetPending"
@@ -187,6 +188,15 @@ class BaseCeleryConfig(object):
             "setup", "tasks", TaskConfigGroup.notify.value, "timeout", default=120
         )
     )
+    notification_orchestrator_soft_time_limit = int(
+        get_config(
+            "setup",
+            "tasks",
+            TaskConfigGroup.notification_orchestrator.value,
+            "timeout",
+            default=120,
+        )
+    )
     timeseries_soft_time_limit = get_config(
         "setup",
         "tasks",
@@ -219,6 +229,10 @@ class BaseCeleryConfig(object):
             "soft_time_limit": notify_soft_time_limit,
             "time_limit": notify_soft_time_limit + 20,
         },
+        notification_orchestrator_task_name: {
+            "soft_time_limit": notification_orchestrator_soft_time_limit,
+            "time_limit": notification_orchestrator_soft_time_limit + 20,
+        },
         sync_repos_task_name: {
             "soft_time_limit": 2 * task_soft_time_limit,
             "time_limit": 2 * task_time_limit,
@@ -305,6 +319,15 @@ class BaseCeleryConfig(object):
                 default=task_default_queue,
             )
         },
+        notification_orchestrator_task_name: {
+            "queue": get_config(
+                "setup",
+                "tasks",
+                TaskConfigGroup.notification_orchestrator.value,
+                "queue",
+                default=task_default_queue,
+            )
+        },
         pulls_task_name: {
             "queue": get_config(
                 "setup",
diff --git a/shared/utils/enums.py b/shared/utils/enums.py
index 7f5bc0a20..3d63802e5 100644
--- a/shared/utils/enums.py
+++ b/shared/utils/enums.py
@@ -33,6 +33,7 @@ class TaskConfigGroup(Enum):
     label_analysis = "label_analysis"
     new_user_activated = "new_user_activated"
     notify = "notify"
+    notification_orchestrator = "notification_orchestrator"
     profiling = "profiling"
     pulls = "pulls"
     send_email = "send_email"
diff --git a/tests/unit/test_celery_config.py b/tests/unit/test_celery_config.py
index 3a0523c46..893c517f3 100644
--- a/tests/unit/test_celery_config.py
+++ b/tests/unit/test_celery_config.py
@@ -21,6 +21,7 @@ def test_celery_config():
     assert hasattr(config, "task_soft_time_limit")
     assert hasattr(config, "task_time_limit")
     assert hasattr(config, "notify_soft_time_limit")
+    assert hasattr(config, "notification_orchestrator_soft_time_limit")
     assert hasattr(config, "task_annotations")
     assert hasattr(config, "task_routes")
     assert hasattr(config, "worker_max_memory_per_child")
@@ -38,6 +39,7 @@ def test_celery_config():
         "app.tasks.label_analysis.*",
         "app.tasks.new_user_activated.NewUserActivated",
         "app.tasks.notify.Notify",
+        "app.tasks.notification_orchestrator.NotificationOrchestrator",
         "app.tasks.profiling.*",
         "app.tasks.pulls.Sync",
         "app.tasks.static_analysis.*",
@@ -83,6 +85,10 @@ def test_celery_config():
             TaskConfigGroup.new_user_activated.value,
         ),
         ("app.tasks.notify.Notify", TaskConfigGroup.notify.value),
+        (
+            "app.tasks.notification_orchestrator.NotificationOrchestrator",
+            TaskConfigGroup.notification_orchestrator.value,
+        ),
         ("app.tasks.profiling.collection", TaskConfigGroup.profiling.value),
         ("app.tasks.profiling.normalizer", TaskConfigGroup.profiling.value),
         ("app.tasks.profiling.summarization", TaskConfigGroup.profiling.value),