From 99bdb3f39f5c705aaa294404e075577c736068c4 Mon Sep 17 00:00:00 2001
From: Tanay Mathur <tanay.mathur@dataintellect.com>
Date: Wed, 25 Mar 2026 09:36:38 +0000
Subject: [PATCH] Modified compressfromtable function to leverage the worker
 multithread ability

---
 code/common/compress.q | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/code/common/compress.q b/code/common/compress.q
index f7e2dc2be..31e133302 100644
--- a/code/common/compress.q
+++ b/code/common/compress.q
@@ -134,7 +134,7 @@ compressfromtable:{[table]
     table:update compressionvaluepre:{(-21!x)`compressedLength}'[fullpath] from table;
     $[0= system"s";
         singlethreadcompress[table];
-        multithreadcompress[table]];
+        $[0<system "s";multithreadcompress[table];{[x;y] compressfromtable select from x where table=y}[table;] peach distinct table`table]];
     / Update the stats tab table after the compression 
     {statstabupdate[x`fullpath;x`calgo;x`currentsize;x`compressionvaluepre]} each table}