diff --git a/lms/djangoapps/discussion/rest_api/tasks.py b/lms/djangoapps/discussion/rest_api/tasks.py
index 8ea3907079..0e152b249d 100644
--- a/lms/djangoapps/discussion/rest_api/tasks.py
+++ b/lms/djangoapps/discussion/rest_api/tasks.py
@@ -3,6 +3,7 @@ Contain celery tasks
 """
 from celery import shared_task
 from django.contrib.auth import get_user_model
+from edx_django_utils.monitoring import set_code_owner_attribute
 from opaque_keys.edx.locator import CourseKey
 from lms.djangoapps.courseware.courses import get_course_with_access
 from openedx.core.djangoapps.django_comment_common.comment_client.thread import Thread
@@ -14,6 +15,7 @@ User = get_user_model()
 
 
 @shared_task
+@set_code_owner_attribute
 def send_thread_created_notification(thread_id, course_key_str, user_id):
     """
     Send notification when a new thread is created
diff --git a/openedx/core/djangoapps/service_status/tasks.py b/openedx/core/djangoapps/service_status/tasks.py
index 6ba3cd3348..61b35d7a4c 100644
--- a/openedx/core/djangoapps/service_status/tasks.py
+++ b/openedx/core/djangoapps/service_status/tasks.py
@@ -6,9 +6,11 @@ Django Celery tasks for service status app
 import time
 
 from celery import current_app as celery
+from edx_django_utils.monitoring import set_code_owner_attribute
 
 
 @celery.task
+@set_code_owner_attribute
 def delayed_ping(value, delay):
     """A simple tasks that replies to a message after a especified amount
     of seconds.