diff --git a/source/util/src/tworker.c b/source/util/src/tworker.c
index 97440f8dae..ca4e5a6f30 100644
--- a/source/util/src/tworker.c
+++ b/source/util/src/tworker.c
@@ -181,7 +181,7 @@ static void *tFWorkerThreadFp(SQWorker *worker) {
 }
 
 STaosQueue *tFWorkerAllocQueue(SQWorkerPool *pool, void *ahandle, FItem fp) {
-  return tWorkerAllocQueue(pool, ahandle, fp, (ThreadFp)tFWorkerThreadFp);
+  return tWorkerAllocQueue(pool, ahandle, fp, (ThreadFp)tQWorkerThreadFp);
 }
 
 void tFWorkerFreeQueue(SFWorkerPool *pool, STaosQueue *queue) { tQWorkerFreeQueue(pool, queue); }