ack comment

Author: waleedlatif1

apps/sim/lib/core/async-jobs/backends/redis.ts

@@ -99,13 +99,14 @@ export class RedisJobQueue implements JobQueueBackend {
 
   async startJob(jobId: string): Promise<void> {
     const now = new Date()
+    const key = KEYS.job(jobId)
 
-    await this.redis.hset(KEYS.job(jobId), {
+    await this.redis.hset(key, {
       status: JOB_STATUS.PROCESSING,
       startedAt: now.toISOString(),
-      attempts: '1',
       updatedAt: now.toISOString(),
     })
+    await this.redis.hincrby(key, 'attempts', 1)
 
     logger.debug('Started job', { jobId })
   }

packages/testing/src/mocks/redis.mock.ts

@@ -21,6 +21,7 @@ export function createMockRedis() {
     hgetall: vi.fn().mockResolvedValue({}),
     hdel: vi.fn().mockResolvedValue(1),
     hmset: vi.fn().mockResolvedValue('OK'),
+    hincrby: vi.fn().mockResolvedValue(1),
 
     // Key operations
     get: vi.fn().mockResolvedValue(null),