v0.6.21: concurrency FF, blog theme

Author: waleedlatif1

apps/sim/lib/blog/mdx.tsx

@@ -44,15 +44,15 @@ export const mdxComponents: MDXRemoteProps['components'] = {
     <p
       {...props}
       style={{ fontSize: '19px', marginBottom: '1.5rem', fontWeight: '400' }}
-      className={clsx('text-[var(--text-subtle)] leading-relaxed', props.className)}
+      className={clsx('text-[var(--landing-text-muted)] leading-relaxed', props.className)}
     />
   ),
   ul: (props: any) => (
     <ul
       {...props}
       style={{ fontSize: '19px', marginBottom: '1rem', fontWeight: '400' }}
       className={clsx(
-        'list-outside list-disc pl-6 text-[var(--text-subtle)] leading-relaxed',
+        'list-outside list-disc pl-6 text-[var(--landing-text-muted)] leading-relaxed',
         props.className
       )}
     />
@@ -62,7 +62,7 @@ export const mdxComponents: MDXRemoteProps['components'] = {
       {...props}
       style={{ fontSize: '19px', marginBottom: '1rem', fontWeight: '400' }}
       className={clsx(
-        'list-outside list-decimal pl-6 text-[var(--text-subtle)] leading-relaxed',
+        'list-outside list-decimal pl-6 text-[var(--landing-text-muted)] leading-relaxed',
         props.className
       )}
     />
@@ -140,7 +140,7 @@ export const mdxComponents: MDXRemoteProps['components'] = {
         <code
           {...props}
           className={clsx(
-            'rounded bg-[var(--surface-4)] px-1.5 py-0.5 font-mono font-normal text-[0.9em] text-[var(--landing-text)]',
+            'rounded bg-[var(--landing-bg-elevated)] px-1.5 py-0.5 font-mono font-normal text-[0.9em] text-[var(--landing-text)]',
             props.className
           )}
           style={{ fontWeight: 400 }}

apps/sim/lib/core/bullmq/connection.ts

@@ -1,8 +1,8 @@
 import type { ConnectionOptions } from 'bullmq'
-import { env } from '@/lib/core/config/env'
+import { env, isTruthy } from '@/lib/core/config/env'
 
 export function isBullMQEnabled(): boolean {
-  return Boolean(env.REDIS_URL)
+  return isTruthy(env.CONCURRENCY_CONTROL_ENABLED) && Boolean(env.REDIS_URL)
 }
 
 export function getBullMQConnectionOptions(): ConnectionOptions {

apps/sim/lib/core/config/env.ts

@@ -187,6 +187,7 @@ export const env = createEnv({
     FREE_PLAN_LOG_RETENTION_DAYS:          z.string().optional(),                  // Log retention days for free plan users
 
     // Admission & Burst Protection
+    CONCURRENCY_CONTROL_ENABLED:           z.string().optional().default('false'),  // Set to 'true' to enable BullMQ-based concurrency control (default: inline execution)
     ADMISSION_GATE_MAX_INFLIGHT:           z.string().optional().default('500'),   // Max concurrent in-flight execution requests per pod
     DISPATCH_MAX_QUEUE_PER_WORKSPACE:      z.string().optional().default('1000'),  // Max queued dispatch jobs per workspace
     DISPATCH_MAX_QUEUE_GLOBAL:             z.string().optional().default('50000'), // Max queued dispatch jobs globally