diff --git a/src/server.cpp b/src/server.cpp
index 3e8517ad8..94709b60f 100644
--- a/src/server.cpp
+++ b/src/server.cpp
@@ -4963,6 +4963,7 @@ bool client::asyncCommand(std::function<void *(const redisDbPersistentDataSnapsh
         return false;
     }
     aeEventLoop *el = serverTL->el;
+    serverAssert(FCorrectThread(this));
     blockClient(this, BLOCKED_ASYNC);
     g_pserver->asyncworkqueue->AddWorkFunction([el, this, preFn, mainFn, postFn, snapshot] {
         void *preData = preFn(snapshot);