diff --git a/Signal/src/Jobs/SessionResetJob.swift b/Signal/src/Jobs/SessionResetJob.swift
index e85538faf..567ea3ced 100644
--- a/Signal/src/Jobs/SessionResetJob.swift
+++ b/Signal/src/Jobs/SessionResetJob.swift
@@ -25,20 +25,26 @@ class SessionResetJob: NSObject {
     func run() {
         Logger.info("\(TAG) Local user reset session.")
 
-        let endSessionMessage = EndSessionMessage(timestamp:NSDate.ows_millisecondTimeStamp(), in: thread)
-        self.messageSender.send(endSessionMessage, success: {
-            Logger.info("\(self.TAG) successfully sent EndSession<essage.")
-
-            Logger.info("\(self.TAG) deleting sessions for recipient: \(self.recipientId)")
+        OWSDispatch.sessionStoreQueue().async {
             self.storageManager.deleteAllSessions(forContact: self.recipientId)
 
-            let message = TSInfoMessage(timestamp: NSDate.ows_millisecondTimeStamp(),
-                                        in: self.thread,
-                                        messageType: TSInfoMessageType.typeSessionDidEnd)
-            message.save()
-        }, failure: {error in
-            Logger.error("\(self.TAG) failed to send EndSesionMessage with error: \(error.localizedDescription)")
-        })
+            DispatchQueue.main.async {
+                let endSessionMessage = EndSessionMessage(timestamp:NSDate.ows_millisecondTimeStamp(), in: self.thread)
+
+                self.messageSender.send(endSessionMessage, success: {
+                    Logger.info("\(self.TAG) successfully sent EndSession<essage.")
+
+                    Logger.info("\(self.TAG) deleting sessions for recipient: \(self.recipientId)")
+
+                    let message = TSInfoMessage(timestamp: NSDate.ows_millisecondTimeStamp(),
+                                                in: self.thread,
+                                                messageType: TSInfoMessageType.typeSessionDidEnd)
+                    message.save()
+                }, failure: {error in
+                    Logger.error("\(self.TAG) failed to send EndSesionMessage with error: \(error.localizedDescription)")
+                })
+            }
+        }
     }
 
     class func run(contactThread: TSContactThread, messageSender: MessageSender, storageManager: TSStorageManager) {