File tree Expand file tree Collapse file tree 1 file changed +7
-6
lines changed
Expand file tree Collapse file tree 1 file changed +7
-6
lines changed Original file line number Diff line number Diff line change @@ -19,8 +19,8 @@ import { Tasks } from '../tasks/_schemas/tasks.schema';
1919import { TasksService } from '../tasks/tasks.service' ;
2020import { ActionType } from './_enum/action-type.enum' ;
2121import { ExecuteJobOptions } from './_interfaces/execute-job-options.interface' ;
22- import { BackendResultInterface } from "~/core/backends/_interfaces/backend-result.interface" ;
23- import { WorkerResultInterface } from "~/core/backends/_interfaces/worker-result.interface" ;
22+ import { BackendResultInterface } from "~/core/backends/_interfaces/backend-result.interface" ;
23+ import { WorkerResultInterface } from "~/core/backends/_interfaces/worker-result.interface" ;
2424
2525const DEFAULT_SYNC_TIMEOUT = 30_000 ;
2626
@@ -234,6 +234,7 @@ export class BackendsService extends AbstractQueueProcessor {
234234 } ,
235235 {
236236 ...options ?. job ,
237+ jobId : ( new Types . ObjectId ( ) ) . toHexString ( ) ,
237238 attempts : 1 ,
238239 } ,
239240 ) ;
@@ -252,10 +253,10 @@ export class BackendsService extends AbstractQueueProcessor {
252253 params : payload ,
253254 concernedTo : identity
254255 ? {
255- $ref : 'identities' ,
256- id : concernedTo ,
257- name : [ identity ?. inetOrgPerson ?. cn , identity ?. inetOrgPerson ?. givenName ] . join ( ' ' ) ,
258- }
256+ $ref : 'identities' ,
257+ id : concernedTo ,
258+ name : [ identity ?. inetOrgPerson ?. cn , identity ?. inetOrgPerson ?. givenName ] . join ( ' ' ) ,
259+ }
259260 : null ,
260261 comment : options ?. comment ,
261262 task : options ?. task ,
You can’t perform that action at this time.
0 commit comments