diff --git a/app/celery/statistics_tasks.py b/app/celery/statistics_tasks.py
new file mode 100644
index 000000000..2712f1a49
--- /dev/null
+++ b/app/celery/statistics_tasks.py
@@ -0,0 +1,9 @@
+from app import notify_celery
+from app.statsd_decorators import statsd
+
+
+@notify_celery.task(bind=True, name='record_initial_job_statistics')
+@statsd(namespace="tasks")
+def record_initial_job_statistics(notification):
+    pass
+
diff --git a/app/dao/statistics_dao.py b/app/dao/statistics_dao.py
new file mode 100644
index 000000000..02ed25e78
--- /dev/null
+++ b/app/dao/statistics_dao.py
@@ -0,0 +1,4 @@
+
+
+def persist_initial_job_statistics(notification):
+    pass
diff --git a/tests/app/dao/test_statistics_dao.py b/tests/app/dao/test_statistics_dao.py
new file mode 100644
index 000000000..a66dfbe42
--- /dev/null
+++ b/tests/app/dao/test_statistics_dao.py
@@ -0,0 +1,19 @@
+from app.dao.statistics_dao import persist_initial_job_statistics
+from app.models import JobStatistics
+from tests.app.conftest import sample_notification
+
+
+def test_should_create_a_stats_entry_for_a_job(
+        notify_db, notify_db_session, sample_service, sample_template, sample_job
+):
+    assert not len(JobStatistics.query.all())
+
+    notification = sample_notification(
+        notify_db, notify_db_session, service=sample_service, template=sample_template, job=sample_job
+    )
+
+    persist_initial_job_statistics(notification)
+
+    stats = JobStatistics.query.all()
+
+    assert len(stats) == 1