From cc5c6246ad3811587363245dad9289ae4c863955 Mon Sep 17 00:00:00 2001
From: Ron Nachum <ronnahom96@gmail.com>
Date: Thu, 27 Apr 2023 16:43:26 +0300
Subject: [PATCH] feat: create task for job

---
 src/jobManagerClient.ts | 29 +++++++++++++++++++++++++++++
 1 file changed, 29 insertions(+)

diff --git a/src/jobManagerClient.ts b/src/jobManagerClient.ts
index 8da26fc..4871546 100644
--- a/src/jobManagerClient.ts
+++ b/src/jobManagerClient.ts
@@ -333,6 +333,35 @@ export class JobManagerClient extends HttpClient {
     }
   }
 
+  public async createTaskForJob<T>(jobId: string, taskBody: ICreateTaskBody<T>): Promise<void> {
+    const createTaskForJobUrl = this.getTaskForJobUrl(jobId);
+    try {
+      this.logger.info({
+        url: createTaskForJobUrl,
+        targetService: this.targetService,
+        jobId,
+        msg: `createTaskForJob jobId=${jobId}`,
+      });
+
+      await this.post(createTaskForJobUrl, taskBody);
+    } catch (err) {
+      this.logger.error({
+        err,
+        url: createTaskForJobUrl,
+        targetService: this.targetService,
+        jobId,
+        msg: `createTaskForJob jobId=${jobId} failed`,
+        errorMessage: (err as { message: string }).message,
+      });
+      throw err;
+    }
+  }
+
+  protected getTaskForJobUrl(jobId: string): string {
+    const taskForJobUrl = `/jobs/${jobId}/tasks`;
+    return taskForJobUrl;
+  }
+
   protected getJobAndTaskUrl(jobId: string, taskId: string): string {
     const taskUrl = `/jobs/${jobId}/tasks/${taskId}`;
     return taskUrl;