chore(backend): Prioritize permission sync jobs for new accounts & repos (#856)

* s

* changelog

* reduce polling interval

Author: brendan-kellam

CHANGELOG.md

@@ -14,6 +14,9 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Fixed issue where the branch filter in the repos detail page would not return any results. [#851](https://github.com/sourcebot-dev/sourcebot/pull/851)
 - Fixed issue where 5xx http errors would not be retried. [#855](https://github.com/sourcebot-dev/sourcebot/pull/855)
 
+### Changed
+- Changed the queuing behaviour for permission syncing to prioritize newly created accounts & repos. [#856](https://github.com/sourcebot-dev/sourcebot/pull/856)
+
 ## [4.10.25] - 2026-02-04
 
 ### Fixed

packages/backend/src/ee/accountPermissionSyncer.ts

@@ -22,6 +22,7 @@ const logger = createLogger(LOG_TAG);
 const createJobLogger = (jobId: string) => createLogger(`${LOG_TAG}:job:${jobId}`);
 
 const QUEUE_NAME = 'accountPermissionSyncQueue';
+const POLLING_INTERVAL_MS = 1000;
 
 type AccountPermissionSyncJob = {
     jobId: string;
@@ -103,7 +104,7 @@ export class AccountPermissionSyncer {
             });
 
             await this.schedulePermissionSync(accounts);
-        }, 1000 * 5);
+        }, POLLING_INTERVAL_MS);
     }
 
     public async dispose() {
@@ -122,6 +123,9 @@ export class AccountPermissionSyncer {
             data: accounts.map(account => ({
                 accountId: account.id,
             })),
+            include: {
+                account: true,
+            }
         });
 
         await this.queue.addBulk(jobs.map((job) => ({
@@ -132,6 +136,8 @@ export class AccountPermissionSyncer {
             opts: {
                 removeOnComplete: env.REDIS_REMOVE_ON_COMPLETE,
                 removeOnFail: env.REDIS_REMOVE_ON_FAIL,
+                // Priority 1 (high) for never-synced, Priority 2 (normal) for re-sync
+                priority: job.account.permissionSyncedAt === null ? 1 : 2,
             }
         })))
     }

packages/backend/src/ee/repoPermissionSyncer.ts

@@ -15,8 +15,9 @@ type RepoPermissionSyncJob = {
 }
 
 const QUEUE_NAME = 'repoPermissionSyncQueue';
-
+const POLLING_INTERVAL_MS = 1000;
 const LOG_TAG = 'repo-permission-syncer';
+
 const logger = createLogger(LOG_TAG);
 const createJobLogger = (jobId: string) => createLogger(`${LOG_TAG}:job:${jobId}`);
 
@@ -107,7 +108,7 @@ export class RepoPermissionSyncer {
             });
 
             await this.schedulePermissionSync(repos);
-        }, 1000 * 5);
+        }, POLLING_INTERVAL_MS);
     }
 
     public async dispose() {
@@ -126,6 +127,9 @@ export class RepoPermissionSyncer {
             data: repos.map(repo => ({
                 repoId: repo.id,
             })),
+            include: {
+                repo: true,
+            }
         });
 
         await this.queue.addBulk(jobs.map((job) => ({
@@ -136,6 +140,8 @@ export class RepoPermissionSyncer {
             opts: {
                 removeOnComplete: env.REDIS_REMOVE_ON_COMPLETE,
                 removeOnFail: env.REDIS_REMOVE_ON_FAIL,
+                // Priority 1 (high) for never-synced, Priority 2 (normal) for re-sync
+                priority: job.repo.permissionSyncedAt === null ? 1 : 2,
             }
         })))
     }