diff --git a/app/celery/statistics_tasks.py b/app/celery/statistics_tasks.py
index 2c746e57b..d7f0fc8c3 100644
--- a/app/celery/statistics_tasks.py
+++ b/app/celery/statistics_tasks.py
@@ -2,21 +2,24 @@ from sqlalchemy.exc import SQLAlchemyError
 
 from app import notify_celery
 from flask import current_app
+
+from app.models import JobStatistics
 from app.statsd_decorators import statsd
 from app.dao.statistics_dao import (
     create_or_update_job_sending_statistics,
     update_job_stats_outcome_count
 )
 from app.dao.notifications_dao import get_notification_by_id
+from app.models import NOTIFICATION_STATUS_TYPES_COMPLETED
 
 
 def create_initial_notification_statistic_tasks(notification):
-    if notification.job_id:
+    if notification.job_id and notification.status not in NOTIFICATION_STATUS_TYPES_COMPLETED:
         record_initial_job_statistics.apply_async((str(notification.id),), queue="statistics")
 
 
 def create_outcome_notification_statistic_tasks(notification):
-    if notification.job_id:
+    if notification.job_id and notification.status in NOTIFICATION_STATUS_TYPES_COMPLETED:
         record_outcome_job_statistics.apply_async((str(notification.id),), queue="statistics")
 
 
diff --git a/tests/app/celery/test_statistics_tasks.py b/tests/app/celery/test_statistics_tasks.py
index ebbb7716e..cdab47b5f 100644
--- a/tests/app/celery/test_statistics_tasks.py
+++ b/tests/app/celery/test_statistics_tasks.py
@@ -1,3 +1,4 @@
+import pytest
 from app.celery.statistics_tasks import (
     record_initial_job_statistics,
     record_outcome_job_statistics,
@@ -6,6 +7,8 @@ from app.celery.statistics_tasks import (
 from sqlalchemy.exc import SQLAlchemyError
 from app import create_uuid
 from tests.app.conftest import sample_notification
+from app.models import NOTIFICATION_STATUS_TYPES_COMPLETED, NOTIFICATION_SENT, NOTIFICATION_SENDING, \
+    NOTIFICATION_PENDING, NOTIFICATION_CREATED, NOTIFICATION_DELIVERED
 
 
 def test_should_create_initial_job_task_if_notification_is_related_to_a_job(
@@ -17,11 +20,34 @@ def test_should_create_initial_job_task_if_notification_is_related_to_a_job(
     mock.assert_called_once_with((str(notification.id), ), queue="statistics")
 
 
-def test_should_not_create_initial_job_task_if_notification_is_related_to_a_job(
-        notify_db, notify_db_session, sample_notification, mocker
+@pytest.mark.parametrize('status', [
+    NOTIFICATION_SENDING, NOTIFICATION_CREATED, NOTIFICATION_PENDING
+])
+def test_should_create_intial_job_task_if_notification_is_not_in_completed_state(
+    notify_db, notify_db_session, sample_job, mocker, status
 ):
     mock = mocker.patch("app.celery.statistics_tasks.record_initial_job_statistics.apply_async")
-    create_initial_notification_statistic_tasks(sample_notification)
+    notification = sample_notification(notify_db, notify_db_session, job=sample_job, status=status)
+    create_initial_notification_statistic_tasks(notification)
+    mock.assert_called_once_with((str(notification.id), ), queue="statistics")
+
+
+@pytest.mark.parametrize('status', NOTIFICATION_STATUS_TYPES_COMPLETED)
+def test_should_not_create_initial_job_task_if_notification_in_completed_state_already(
+    notify_db, notify_db_session, sample_job, mocker, status
+):
+    mock = mocker.patch("app.celery.statistics_tasks.record_initial_job_statistics.apply_async")
+    notification = sample_notification(notify_db, notify_db_session, job=sample_job, status=status)
+    create_initial_notification_statistic_tasks(notification)
+    mock.assert_not_called()
+
+
+def test_should_not_create_initial_job_task_if_notification_is_not_related_to_a_job(
+        notify_db, notify_db_session, mocker
+):
+    notification = sample_notification(notify_db, notify_db_session, status=NOTIFICATION_CREATED)
+    mock = mocker.patch("app.celery.statistics_tasks.record_initial_job_statistics.apply_async")
+    create_initial_notification_statistic_tasks(notification)
     mock.assert_not_called()
 
 
@@ -29,12 +55,34 @@ def test_should_create_outcome_job_task_if_notification_is_related_to_a_job(
         notify_db, notify_db_session, sample_job, mocker
 ):
     mock = mocker.patch("app.celery.statistics_tasks.record_outcome_job_statistics.apply_async")
-    notification = sample_notification(notify_db, notify_db_session, job=sample_job)
+    notification = sample_notification(notify_db, notify_db_session, job=sample_job, status=NOTIFICATION_DELIVERED)
     create_outcome_notification_statistic_tasks(notification)
     mock.assert_called_once_with((str(notification.id), ), queue="statistics")
 
 
-def test_should_not_create_outcome_job_task_if_notification_is_related_to_a_job(
+@pytest.mark.parametrize('status', NOTIFICATION_STATUS_TYPES_COMPLETED)
+def test_should_create_outcome_job_task_if_notification_is_in_completed_state(
+    notify_db, notify_db_session, sample_job, mocker, status
+):
+    mock = mocker.patch("app.celery.statistics_tasks.record_outcome_job_statistics.apply_async")
+    notification = sample_notification(notify_db, notify_db_session, job=sample_job, status=status)
+    create_outcome_notification_statistic_tasks(notification)
+    mock.assert_called_once_with((str(notification.id), ), queue='statistics')
+
+
+@pytest.mark.parametrize('status', [
+    NOTIFICATION_SENDING, NOTIFICATION_CREATED, NOTIFICATION_PENDING
+])
+def test_should_not_create_outcome_job_task_if_notification_is_not_in_completed_state_already(
+    notify_db, notify_db_session, sample_job, mocker, status
+):
+    mock = mocker.patch("app.celery.statistics_tasks.record_initial_job_statistics.apply_async")
+    notification = sample_notification(notify_db, notify_db_session, job=sample_job, status=status)
+    create_outcome_notification_statistic_tasks(notification)
+    mock.assert_not_called()
+
+
+def test_should_not_create_outcome_job_task_if_notification_is_not_related_to_a_job(
         notify_db, notify_db_session, sample_notification, mocker
 ):
     mock = mocker.patch("app.celery.statistics_tasks.record_outcome_job_statistics.apply_async")