@@ -17,7 +17,9 @@ type RepoPermissionSyncJob = {
1717
1818const QUEUE_NAME = 'repoPermissionSyncQueue' ;
1919
20- const logger = createLogger ( 'repo-permission-syncer' ) ;
20+ const LOG_TAG = 'repo-permission-syncer' ;
21+ const logger = createLogger ( LOG_TAG ) ;
22+ const createJobLogger = ( jobId : string ) => createLogger ( `${ LOG_TAG } :job:${ jobId } ` ) ;
2123
2224export class RepoPermissionSyncer {
2325 private queue : Queue < RepoPermissionSyncJob > ;
@@ -133,6 +135,8 @@ export class RepoPermissionSyncer {
133135
134136 private async runJob ( job : Job < RepoPermissionSyncJob > ) {
135137 const id = job . data . jobId ;
138+ const logger = createJobLogger ( id ) ;
139+
136140 const { repo } = await this . db . repoPermissionSyncJob . update ( {
137141 where : {
138142 id,
@@ -250,6 +254,8 @@ export class RepoPermissionSyncer {
250254 }
251255
252256 private async onJobCompleted ( job : Job < RepoPermissionSyncJob > ) {
257+ const logger = createJobLogger ( job . data . jobId ) ;
258+
253259 const { repo } = await this . db . repoPermissionSyncJob . update ( {
254260 where : {
255261 id : job . data . jobId ,
@@ -272,6 +278,8 @@ export class RepoPermissionSyncer {
272278 }
273279
274280 private async onJobFailed ( job : Job < RepoPermissionSyncJob > | undefined , err : Error ) {
281+ const logger = createJobLogger ( job ?. data . jobId ?? 'unknown' ) ;
282+
275283 Sentry . captureException ( err , {
276284 tags : {
277285 jobId : job ?. data . jobId ,
0 commit comments