sourcebot-dev · brendan-kellam · May 8, 2026 · May 6, 2026 · May 6, 2026 · May 6, 2026
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -11,6 +11,9 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Add missing schema changes introduced in [#1170](https://github.com/sourcebot-dev/sourcebot/pull/1170). [#1176](https://github.com/sourcebot-dev/sourcebot/pull/1176)
 - Fixed blame gutter commit navigation to use the file path as it existed at the attributing commit, so clicking a blame line whose commit predates a rename resolves to the correct historical path. [#1178](https://github.com/sourcebot-dev/sourcebot/pull/1178)
 
+### Changed
+- Reduced the log verbosity of the worker by changing various log messages from info to debug. [#1179](https://github.com/sourcebot-dev/sourcebot/pull/1179)
+
 ## [4.17.1] - 2026-05-04
 
 ### Added

diff --git a/packages/backend/src/api.ts b/packages/backend/src/api.ts
@@ -42,7 +42,7 @@ export class Api {
         app.post(`/api/experimental/add-github-repo`, this.experimental_addGithubRepo.bind(this));
 
         this.server = app.listen(PORT, () => {
-            logger.info(`API server is running on port ${PORT}`);
+            logger.debug(`API server is running on port ${PORT}`);
         });
     }
 

diff --git a/packages/backend/src/configManager.ts b/packages/backend/src/configManager.ts
@@ -28,7 +28,7 @@ export class ConfigManager {
         });
 
         this.watcher.on('change', async () => {
-            logger.info(`Config file ${configPath} changed. Syncing config.`);
+            logger.debug(`Config file ${configPath} changed. Syncing config.`);
             try {
                 await this.syncConfig(configPath);
             } catch (error) {
@@ -101,7 +101,7 @@ export class ConfigManager {
                     });
 
                 if (connectionNeedsSyncing) {
-                    logger.info(`Change detected for connection '${key}' (id: ${connection.id}). Creating sync job.`);
+                    logger.debug(`Change detected for connection '${key}' (id: ${connection.id}). Creating sync job.`);
                     await this.connectionManager.createJobs([connection]);
                 }
             }
@@ -119,7 +119,7 @@ export class ConfigManager {
         });
 
         for (const connection of deletedConnections) {
-            logger.info(`Deleting connection with name '${connection.name}'. Connection ID: ${connection.id}`);
+            logger.debug(`Deleting connection with name '${connection.name}'. Connection ID: ${connection.id}`);
             await this.db.connection.delete({
                 where: {
                     id: connection.id,

diff --git a/packages/backend/src/connectionManager.ts b/packages/backend/src/connectionManager.ts
@@ -137,7 +137,7 @@ export class ConnectionManager {
         });
 
         for (const job of jobs) {
-            logger.info(`Scheduling job ${job.id} for connection ${job.connection.name} (id: ${job.connectionId})`);
+            logger.debug(`Scheduling job ${job.id} for connection ${job.connection.name} (id: ${job.connectionId})`);
             await this.queue.add(
                 'connection-sync-job',
                 {
@@ -158,7 +158,7 @@ export class ConnectionManager {
     private async runJob(job: Job<JobPayload>): Promise<JobResult> {
         const { jobId, connectionName } = job.data;
         const logger = createJobLogger(jobId);
-        logger.info(`Running connection sync job ${jobId} for connection ${connectionName} (id: ${job.data.connectionId})`);
+        logger.debug(`Running connection sync job ${jobId} for connection ${connectionName} (id: ${job.data.connectionId})`);
 
         const currentStatus = await this.db.connectionSyncJob.findUniqueOrThrow({
             where: {
@@ -261,7 +261,7 @@ export class ConnectionManager {
                 }
             });
             const deleteDuration = performance.now() - deleteStart;
-            logger.info(`Deleted all RepoToConnection records for connection ${connectionName} (id: ${job.data.connectionId}) in ${deleteDuration}ms`);
+            logger.debug(`Deleted all RepoToConnection records for connection ${connectionName} (id: ${job.data.connectionId}) in ${deleteDuration}ms`);
 
             const totalUpsertStart = performance.now();
             for (const repo of repoData) {
@@ -281,7 +281,7 @@ export class ConnectionManager {
                 logger.debug(`Upserted repo ${repo.displayName} (id: ${repo.external_id}) in ${upsertDuration}ms`);
             }
             const totalUpsertDuration = performance.now() - totalUpsertStart;
-            logger.info(`Upserted ${repoData.length} repos for connection ${connectionName} (id: ${job.data.connectionId}) in ${totalUpsertDuration}ms`);
+            logger.debug(`Upserted ${repoData.length} repos for connection ${connectionName} (id: ${job.data.connectionId}) in ${totalUpsertDuration}ms`);
         }, { timeout: env.CONNECTION_MANAGER_UPSERT_TIMEOUT_MS });
 
         return {
@@ -330,7 +330,7 @@ export class ConnectionManager {
                 }
             }
 
-            logger.info(`Connection sync job ${job.id} for connection ${job.data.connectionName} (id: ${job.data.connectionId}) completed`);
+            logger.debug(`Connection sync job ${job.id} for connection ${job.data.connectionName} (id: ${job.data.connectionId}) completed`);
 
             this.promClient.activeConnectionSyncJobs.dec({ connection: connectionName });
             this.promClient.connectionSyncJobSuccessTotal.inc({ connection: connectionName });

diff --git a/packages/backend/src/ee/auditLogPruner.ts b/packages/backend/src/ee/auditLogPruner.ts
@@ -23,7 +23,7 @@ export class AuditLogPruner {
             return;
         }
 
-        logger.info(`Audit log pruner started. Retaining logs for ${env.SOURCEBOT_EE_AUDIT_RETENTION_DAYS} days.`);
+        logger.debug(`Audit log pruner started. Retaining logs for ${env.SOURCEBOT_EE_AUDIT_RETENTION_DAYS} days.`);
 
         // Run immediately on startup, then every 24 hours
         this.pruneOldAuditLogs();
@@ -41,7 +41,7 @@ export class AuditLogPruner {
         const cutoff = new Date(Date.now() - env.SOURCEBOT_EE_AUDIT_RETENTION_DAYS * ONE_DAY_MS);
         let totalDeleted = 0;
 
-        logger.info(`Pruning audit logs older than ${cutoff.toISOString()}...`);
+        logger.debug(`Pruning audit logs older than ${cutoff.toISOString()}...`);
 
         // Delete in batches to avoid long-running transactions
         while (true) {
@@ -63,9 +63,9 @@ export class AuditLogPruner {
         }
 
         if (totalDeleted > 0) {
-            logger.info(`Pruned ${totalDeleted} audit log records.`);
+            logger.debug(`Pruned ${totalDeleted} audit log records.`);
         } else {
-            logger.info('No audit log records to prune.');
+            logger.debug('No audit log records to prune.');
         }
     }
 }
diff --git a/packages/backend/src/index.ts b/packages/backend/src/index.ts
@@ -41,7 +41,7 @@ const prisma = new PrismaClient({
 
 try {
     await redis.ping();
-    logger.info('Connected to redis');
+    logger.debug('Connected to redis');
 } catch (err: unknown) {
     logger.error('Failed to connect to redis. Error:', err);
     process.exit(1);

diff --git a/packages/backend/src/repoIndexManager.ts b/packages/backend/src/repoIndexManager.ts
@@ -279,7 +279,7 @@ export class RepoIndexManager {
     private async runJob(job: Job<JobPayload>, signal: AbortSignal) {
         const id = job.data.jobId;
         const logger = createJobLogger(id);
-        logger.info(`Running ${job.data.type} job ${id} for repo ${job.data.repoName} (id: ${job.data.repoId})`);
+        logger.debug(`Running ${job.data.type} job ${id} for repo ${job.data.repoName} (id: ${job.data.repoId})`);
 
         const currentStatus = await this.db.repoIndexingJob.findUniqueOrThrow({
             where: {
@@ -383,7 +383,7 @@ export class RepoIndexManager {
                 signal,
             });
 
-            logger.info(`Fetching ${repo.name} (id: ${repo.id})...`);
+            logger.debug(`Fetching ${repo.name} (id: ${repo.id})...`);
             const { durationMs } = await measure(() => fetchRepository({
                 cloneUrl: cloneUrlMaybeWithToken,
                 authHeader,
@@ -395,10 +395,9 @@ export class RepoIndexManager {
             }));
             const fetchDuration_s = durationMs / 1000;
 
-            process.stdout.write('\n');
-            logger.info(`Fetched ${repo.name} (id: ${repo.id}) in ${fetchDuration_s}s`);
+            logger.debug(`Fetched ${repo.name} (id: ${repo.id}) in ${fetchDuration_s}s`);
         } else if (!isReadOnly) {
-            logger.info(`Cloning ${repo.name} (id: ${repo.id})...`);
+            logger.debug(`Cloning ${repo.name} (id: ${repo.id})...`);
 
             const { durationMs } = await measure(() => cloneRepository({
                 cloneUrl: cloneUrlMaybeWithToken,
@@ -411,8 +410,7 @@ export class RepoIndexManager {
             }));
             const cloneDuration_s = durationMs / 1000;
 
-            process.stdout.write('\n');
-            logger.info(`Cloned ${repo.name} (id: ${repo.id}) in ${cloneDuration_s}s`);
+            logger.debug(`Cloned ${repo.name} (id: ${repo.id}) in ${cloneDuration_s}s`);
         }
 
         // Regardless of clone or fetch, always upsert the git config for the repo.
@@ -478,11 +476,11 @@ export class RepoIndexManager {
             revisions = revisions.slice(0, 64);
         }
 
-        logger.info(`Indexing ${repo.name} (id: ${repo.id})...`);
+        logger.debug(`Indexing ${repo.name} (id: ${repo.id})...`);
         try {
             const { durationMs } = await measure(() => indexGitRepository(repo, this.settings, revisions, signal));
             const indexDuration_s = durationMs / 1000;
-            logger.info(`Indexed ${repo.name} (id: ${repo.id}) in ${indexDuration_s}s`);
+            logger.debug(`Indexed ${repo.name} (id: ${repo.id}) in ${indexDuration_s}s`);
         } catch (error) {
             // Clean up any temporary shard files left behind by the failed indexing operation.
             // Zoekt creates .tmp files during indexing which can accumulate if indexing fails repeatedly.
@@ -497,15 +495,15 @@ export class RepoIndexManager {
     private async cleanupRepository(repo: Repo, logger: Logger) {
         const { path: repoPath, isReadOnly } = getRepoPath(repo);
         if (existsSync(repoPath) && !isReadOnly) {
-            logger.info(`Deleting repo directory ${repoPath}`);
+            logger.debug(`Deleting repo directory ${repoPath}`);
             await rm(repoPath, { recursive: true, force: true });
         }
 
         const shardPrefix = getShardPrefix(repo.orgId, repo.id);
         const files = (await readdir(INDEX_CACHE_DIR)).filter(file => file.startsWith(shardPrefix));
         for (const file of files) {
             const filePath = `${INDEX_CACHE_DIR}/${file}`;
-            logger.info(`Deleting shard file ${filePath}`);
+            logger.debug(`Deleting shard file ${filePath}`);
             await rm(filePath, { force: true });
         }
     }
@@ -564,14 +562,14 @@ export class RepoIndexManager {
                     }
                 });
 
-                logger.info(`Completed index job ${job.data.jobId} for repo ${repo.name} (id: ${repo.id})`);
+                logger.debug(`Completed index job ${job.data.jobId} for repo ${repo.name} (id: ${repo.id})`);
             }
             else if (jobData.type === RepoIndexingJobType.CLEANUP) {
                 const repo = await this.db.repo.delete({
                     where: { id: jobData.repoId },
                 });
 
-                logger.info(`Completed cleanup job ${job.data.jobId} for repo ${repo.name} (id: ${repo.id})`);
+                logger.debug(`Completed cleanup job ${job.data.jobId} for repo ${repo.name} (id: ${repo.id})`);
             }
 
             // Track metrics for successful job
@@ -604,7 +602,7 @@ export class RepoIndexManager {
             // or if it is being retried.
             const jobState = await job.getState();
             if (jobState !== 'failed') {
-                jobLogger.warn(`Job ${job.id} for repo ${job.data.repoName} (id: ${job.data.repoId}) failed. Retrying...`);
+                jobLogger.warn(`Job ${job.id} for repo ${job.data.repoName} (id: ${job.data.repoId}) failed. Retrying... Reason: ${error.message}`);
                 return;
             }
 
@@ -626,7 +624,7 @@ export class RepoIndexManager {
             this.promClient.activeRepoIndexJobs.dec({ repo: job.data.repoName, type: jobTypeLabel });
             this.promClient.repoIndexJobFailTotal.inc({ repo: job.data.repoName, type: jobTypeLabel });
 
-            jobLogger.error(`Failed job ${job.data.jobId} for repo ${repo.name} (id: ${repo.id}).`);
+            jobLogger.error(`Failed job ${job.data.jobId} for repo ${repo.name} (id: ${repo.id}). Reason: ${error.message}`);
 
             captureEvent('backend_repo_index_job_failed', {
                 repoId: job.data.repoId,
@@ -664,7 +662,7 @@ export class RepoIndexManager {
                 const existingIds = new Set(existingRepos.map(r => r.id));
                 for (const [repoId, repoPath] of repoIdToPath) {
                     if (!existingIds.has(repoId)) {
-                        logger.info(`Removing orphaned repo directory with no DB record: ${repoPath}`);
+                        logger.debug(`Removing orphaned repo directory with no DB record: ${repoPath}`);
                         await rm(repoPath, { recursive: true, force: true });
                     }
                 }
@@ -695,7 +693,7 @@ export class RepoIndexManager {
                     if (!existingIds.has(repoId)) {
                         for (const entry of shards) {
                             const shardPath = `${INDEX_CACHE_DIR}/${entry}`;
-                            logger.info(`Removing orphaned index shard with no DB record: ${shardPath}`);
+                            logger.debug(`Removing orphaned index shard with no DB record: ${shardPath}`);
                             await rm(shardPath, { force: true });
                         }
                     }

diff --git a/packages/backend/src/zoekt.ts b/packages/backend/src/zoekt.ts
@@ -37,14 +37,12 @@ export const indexGitRepository = async (repo: Repo, settings: Settings, revisio
 
             if (stdout) {
                 stdout.split('\n').filter(line => line.trim()).forEach(line => {
-                    logger.info(line);
+                    logger.debug(line);
                 });
             }
             if (stderr) {
                 stderr.split('\n').filter(line => line.trim()).forEach(line => {
-                    // TODO: logging as regular info here and not error because non error logs are being
-                    // streamed in stderr and incorrectly being logged as errors at a high level
-                    logger.info(line);
+                    logger.debug(line);
                 });
             }
 

diff --git a/packages/web/src/app/api/(server)/health/route.ts b/packages/web/src/app/api/(server)/health/route.ts
@@ -6,7 +6,7 @@ import { createLogger } from "@sourcebot/shared";
 const logger = createLogger('health-check');
 
 export const GET = apiHandler(async () => {
-    logger.info('health check');
+    logger.debug('health check');
     return Response.json({ status: 'ok' });
 }, { track: false });