Spaces:
Runtime error
Runtime error
Commit ·
c021ed8
1
Parent(s): c3290dc
refactor(redis-queue): reduce logging verbosity in enqueue and dequeue operations
Browse files- Remove debug log from enqueue method that logged sync operation details
- Remove debug log from dequeue method timeout exception handler
- Decrease noise in queue operations to improve log clarity and performance
app/sync/common/redis_queue.py
CHANGED
|
@@ -88,17 +88,6 @@ class RedisSyncQueue:
|
|
| 88 |
# Update stats
|
| 89 |
await self.redis_client.hincrby(self.stats_key, "total_enqueued", 1)
|
| 90 |
|
| 91 |
-
logger.debug(
|
| 92 |
-
f"Enqueued sync operation",
|
| 93 |
-
extra={
|
| 94 |
-
"queue_name": self.queue_name,
|
| 95 |
-
"entity_type": sync_op.entity_type,
|
| 96 |
-
"entity_id": sync_op.entity_id,
|
| 97 |
-
"operation": sync_op.operation,
|
| 98 |
-
"queue_size": current_size + 1
|
| 99 |
-
}
|
| 100 |
-
)
|
| 101 |
-
|
| 102 |
return True
|
| 103 |
|
| 104 |
except Exception as e:
|
|
@@ -157,7 +146,6 @@ class RedisSyncQueue:
|
|
| 157 |
return sync_op
|
| 158 |
|
| 159 |
except asyncio.TimeoutError:
|
| 160 |
-
logger.debug(f"Dequeue asyncio timeout on {self.queue_name}")
|
| 161 |
return None
|
| 162 |
except Exception as e:
|
| 163 |
logger.error(
|
|
|
|
| 88 |
# Update stats
|
| 89 |
await self.redis_client.hincrby(self.stats_key, "total_enqueued", 1)
|
| 90 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 91 |
return True
|
| 92 |
|
| 93 |
except Exception as e:
|
|
|
|
| 146 |
return sync_op
|
| 147 |
|
| 148 |
except asyncio.TimeoutError:
|
|
|
|
| 149 |
return None
|
| 150 |
except Exception as e:
|
| 151 |
logger.error(
|