diff --git a/src/data/threads.js b/src/data/threads.js
index 9a0f498..d9042a8 100644
--- a/src/data/threads.js
+++ b/src/data/threads.js
@@ -206,6 +206,7 @@ async function getThreadsThatShouldBeClosed() {
     .where('status', THREAD_STATUS.OPEN)
     .whereNotNull('scheduled_close_at')
     .where('scheduled_close_at', '<=', now)
+    .whereNotNull('scheduled_close_at')
     .select();
 
   return threads.map(thread => new Thread(thread));