feat(gql): processingTime Job field

s-r-x · Jul 27, 2021 · 841fb7e · 841fb7e
1 parent 3ac8400
commit 841fb7e
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 0 deletions.
diff --git a/packages/root/src/gql/data-sources/bull/index.ts b/packages/root/src/gql/data-sources/bull/index.ts
@@ -144,6 +144,10 @@ export class BullDataSource extends DataSource {
     }
     return job;
   }
+  extractJobProcessingTime(job: Job): number {
+    if (!job.processedOn || !job.finishedOn) return 0;
+    return job.finishedOn - job.processedOn;
+  }
   async getJobLogs(queueName: string, id: number) {
     const queue = this.getQueueByName(queueName, true);
     return await queue?.getJobLogs(id);

diff --git a/packages/root/src/gql/resolvers/job.ts b/packages/root/src/gql/resolvers/job.ts
@@ -18,6 +18,9 @@ export const JobResolver: TResolvers = {
     delay({ opts }: BullJob) {
       return opts.delay;
     },
+    processingTime(job: BullJob, _vars, { dataSources: { bull } }) {
+      return bull.extractJobProcessingTime(job);
+    },
     logs(job: BullJob, _vars, { dataSources: { bull } }) {
       return bull.getJobLogs(job.queue.name, job.id as number);
     },

diff --git a/packages/root/src/gql/type-defs/job.ts b/packages/root/src/gql/type-defs/job.ts
@@ -37,6 +37,7 @@ export const jobTypeDef = gql`
     timestamp: Float!
     finishedOn: Float
     processedOn: Float
+    processingTime: Float
     opts: String!
   }
 `;
diff --git a/packages/root/src/typings/gql.ts b/packages/root/src/typings/gql.ts
@@ -43,6 +43,7 @@ export type Job = {
   timestamp: Scalars['Float'];
   finishedOn?: Maybe<Scalars['Float']>;
   processedOn?: Maybe<Scalars['Float']>;
+  processingTime?: Maybe<Scalars['Float']>;
   opts: Scalars['String'];
 };
 
@@ -270,6 +271,7 @@ export type QueryJobArgs = {
 
 export type Queue = {
   name: Scalars['String'];
+  keyPrefix?: Maybe<Scalars['String']>;
   /** https://github.com/OptimalBits/bull/blob/develop/REFERENCE.md#queuecount */
   count: Scalars['Int'];
   /** https://github.com/OptimalBits/bull/blob/develop/REFERENCE.md#queuegetjobcounts */