fix(tables): address review — drizzle operators for orphan filter, enabled flag for files query

- dispatcher: replace the `not(and(...)) as SQL` cast in countRunningCells with
  `or(ne(status,'pending'), isNotNull(executionId))` — De Morgan equivalent,
  fully type-checked, no cast and no hand-written raw SQL.
- workspace-files: add an `enabled` option to useWorkspaceFiles; sim-resource
  cell now passes the real workspaceId with `enabled` instead of '' so the
  query cache isn't polluted with an empty-key entry.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Author: TheodoreSpeaks

apps/sim/app/workspace/[workspaceId]/tables/[tableId]/components/table-grid/cells/sim-resource-cell.tsx

@@ -50,7 +50,9 @@ export function SimResourceCell({
   const { data: knowledgeBases = [] } = useKnowledgeBasesQuery(workspaceId, {
     enabled: resourceType === 'knowledge',
   })
-  const { data: files = [] } = useWorkspaceFiles(resourceType === 'file' ? workspaceId : '')
+  const { data: files = [] } = useWorkspaceFiles(workspaceId, 'active', {
+    enabled: resourceType === 'file',
+  })
 
   const workflow =
     resourceType === 'workflow' ? workflows.find((w) => w.id === resourceId) : undefined

apps/sim/hooks/queries/workspace-files.ts

@@ -98,11 +98,15 @@ async function fetchWorkspaceFiles(
 /**
  * Hook to fetch workspace files
  */
-export function useWorkspaceFiles(workspaceId: string, scope: WorkspaceFileQueryScope = 'active') {
+export function useWorkspaceFiles(
+  workspaceId: string,
+  scope: WorkspaceFileQueryScope = 'active',
+  options?: { enabled?: boolean }
+) {
   return useQuery({
     queryKey: workspaceFilesKeys.list(workspaceId, scope),
     queryFn: ({ signal }) => fetchWorkspaceFiles(workspaceId, scope, signal),
-    enabled: !!workspaceId,
+    enabled: !!workspaceId && (options?.enabled ?? true),
     staleTime: 30 * 1000, // 30 seconds - files can change frequently
     placeholderData: keepPreviousData, // Show cached data immediately
   })

apps/sim/lib/table/dispatcher.ts

@@ -3,7 +3,7 @@ import { tableRowExecutions, tableRunDispatches, userTableRows } from '@sim/db/s
 import { createLogger } from '@sim/logger'
 import { toError } from '@sim/utils/errors'
 import { generateId } from '@sim/utils/id'
-import { and, asc, eq, gt, inArray, isNull, not, type SQL, sql } from 'drizzle-orm'
+import { and, asc, eq, gt, inArray, isNotNull, ne, or, type SQL, sql } from 'drizzle-orm'
 import { getJobQueue } from '@/lib/core/async-jobs/config'
 import { writeWorkflowGroupState } from '@/lib/table/cell-write'
 import { appendTableEvent } from '@/lib/table/events'
@@ -208,12 +208,9 @@ export async function countRunningCells(
       and(
         eq(tableRowExecutions.tableId, tableId),
         inArray(tableRowExecutions.status, ['queued', 'running', 'pending']),
-        not(
-          and(
-            eq(tableRowExecutions.status, 'pending'),
-            isNull(tableRowExecutions.executionId)
-          ) as SQL
-        )
+        // Exclude orphan pre-stamps (`pending` + null executionId). De Morgan of
+        // NOT(pending AND null) — `status` is NOT NULL so `ne` is well-defined.
+        or(ne(tableRowExecutions.status, 'pending'), isNotNull(tableRowExecutions.executionId))
       )
     )
     .groupBy(tableRowExecutions.rowId)