Skip to content

Commit b8ed25d

Browse files
committed
Update
1 parent e3c9d0e commit b8ed25d

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

backend/services/graphql_retry_worker.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -39,14 +39,14 @@ def _retry_worker_loop():
3939
queue_size = get_queue_size()
4040

4141
if queue_size > 0:
42-
logger.info(f"📊 Iteration {iteration}: Processing retry queue ({queue_size} items pending)")
42+
logger.info(f"Iteration {iteration}: Processing retry queue ({queue_size} items pending)")
4343

4444
stats = process_retry_queue(max_items=BATCH_SIZE)
4545

4646
if stats['success'] > 0 or stats['failed'] > 0:
4747
remaining = get_queue_size()
4848
logger.info(
49-
f"Batch complete: {stats['success']} synced, "
49+
f"Batch complete: {stats['success']} synced, "
5050
f"{stats['failed']} failed, {stats['skipped']} skipped. "
5151
f"Remaining: {remaining}"
5252
)
@@ -55,13 +55,13 @@ def _retry_worker_loop():
5555
logger.debug(f"💤 Iteration {iteration}: Queue empty")
5656

5757
except Exception as e:
58-
logger.error(f"Error in retry worker iteration {iteration}: {e}")
58+
logger.error(f"Error in retry worker iteration {iteration}: {e}")
5959
logger.exception("Full traceback:")
6060

6161
# Wait with ability to interrupt on shutdown
6262
_stop_event.wait(RETRY_INTERVAL_SECONDS)
6363

64-
logger.info("🛑 GraphQL Retry Worker stopped")
64+
logger.info("GraphQL Retry Worker stopped")
6565

6666

6767
def start_retry_worker():

0 commit comments

Comments
 (0)