chore(worker): Reduce logger verbosity (#1179)

Author: brendan-kellam

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

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}`);
         });
     }
 

packages/backend/src/azuredevops.ts

@@ -291,7 +291,7 @@ async function getRepos(
     const results = await Promise.allSettled(repoList.map(async (repo) => {
         try {
             const [org, projectName, repoName] = repo.split('/');
-            logger.info(`Fetching repository info for ${repo}...`);
+            logger.debug(`Fetching repository info for ${repo}...`);
 
             const { durationMs, data: result } = await measure(async () => {
                 const fetchFn = async () => {
@@ -306,7 +306,7 @@ async function getRepos(
                 return fetchWithRetry(fetchFn, repo, logger);
             });
 
-            logger.info(`Found info for repository ${repo} in ${durationMs}ms`);
+            logger.debug(`Found info for repository ${repo} in ${durationMs}ms`);
             return {
                 type: 'valid' as const,
                 data: [result]

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,

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 });

packages/backend/src/ee/accountPermissionSyncer.ts

@@ -181,7 +181,7 @@ export class AccountPermissionSyncer {
 
         const config = await loadConfig(env.CONFIG_PATH);
 
-        logger.info(`Syncing permissions for ${account.provider} account (id: ${account.id}) for user ${account.user.email}...`);
+        logger.debug(`Syncing permissions for ${account.provider} account (id: ${account.id}) for user ${account.user.email}...`);
 
         // Ensure the OAuth token is fresh, refreshing it if it is expired or near expiry.
         // Throws and sets Account.tokenRefreshErrorMessage if the refresh fails.
@@ -370,7 +370,7 @@ export class AccountPermissionSyncer {
             }
         });
 
-        logger.info(`Permissions synced for ${account.provider} account (id: ${account.id}) for user ${account.user.email}`);
+        logger.debug(`Permissions synced for ${account.provider} account (id: ${account.id}) for user ${account.user.email}`);
     }
 
     private async onJobFailed(job: Job<AccountPermissionSyncJob> | undefined, err: Error) {

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.');
         }
     }
 }

packages/backend/src/ee/repoPermissionSyncer.ts

@@ -186,7 +186,7 @@ export class RepoPermissionSyncer {
             throw new Error(`Repo ${id} not found`);
         }
 
-        logger.info(`Syncing permissions for repo ${repo.displayName}...`);
+        logger.debug(`Syncing permissions for repo ${repo.displayName}...`);
 
         const credentials = await getAuthCredentialsForRepo(repo, logger);
         if (!credentials) {
@@ -388,7 +388,7 @@ export class RepoPermissionSyncer {
             }
         });
 
-        logger.info(`Permissions synced for repo ${repo.displayName ?? repo.name}`);
+        logger.debug(`Permissions synced for repo ${repo.displayName ?? repo.name}`);
     }
 
     private async onJobFailed(job: Job<RepoPermissionSyncJob> | undefined, err: Error) {

packages/backend/src/ee/syncSearchContexts.ts

@@ -205,7 +205,7 @@ export const syncSearchContexts = async (params: SyncSearchContextsParams) => {
     });
 
     for (const context of deletedContexts) {
-        logger.info(`Deleting search context with name '${context.name}'. ID: ${context.id}`);
+        logger.debug(`Deleting search context with name '${context.name}'. ID: ${context.id}`);
         await db.searchContext.delete({
             where: {
                 id: context.id,

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);