chore: temp commit

kindredgroup · May 28, 2024 · 177f478 · 177f478
1 parent 5c93b5a
commit 177f478
Showing 1 changed file with 17 additions and 15 deletions.
diff --git a/scylla_pg_client/index.ts b/scylla_pg_client/index.ts
@@ -1,12 +1,12 @@
-import {JsAddTaskModel, JsDbConfig, JsGetTasksModel, ScyllaManager} from "scylla_pg_js";
+import { JsAddTaskModel, JsDbConfig, JsGetTasksModel, ScyllaManager } from "scylla_pg_js";
 
 
 export enum TaskStatus {
-  running="running",
-  ready="ready",
-  cancelled="cancelled",
-  completed="completed",
-  aborted="aborted"
+  running = "running",
+  ready = "ready",
+  cancelled = "cancelled",
+  completed = "completed",
+  aborted = "aborted"
 }
 
 export enum TaskHistoryType {
@@ -71,7 +71,7 @@ class Scylla {
     this.scyllaManager = sc
   }
   public static async initiate(dbConfig: DbConfig): Promise<Scylla> {
-   let scyllaManager: ScyllaManager = await ScyllaManager.initPgConfig(dbConfig as JsDbConfig)
+    let scyllaManager: ScyllaManager = await ScyllaManager.initPgConfig(dbConfig as JsDbConfig)
     let sc = new Scylla(scyllaManager);
     return sc;
   }
@@ -84,8 +84,10 @@ class Scylla {
     return JSON.parse(resp);
   }
   public async addTask(addTaskModel: AddTaskModel): Promise<Task> {
+    console.log("Scylla manager...", this.scyllaManager)
+    console.log("Scylla manage addTaskModelr...", addTaskModel)
     if (!addTaskModel || !addTaskModel.spec) {
-      throw Error ( "Invalid argument. addTaskModel.spec cannot be undefined" );
+      throw Error("Invalid argument. addTaskModel.spec cannot be undefined");
     }
     let atm: JsAddTaskModel = {
       ...addTaskModel,
@@ -100,10 +102,10 @@ class Scylla {
     return JSON.parse(response);
   }
 
-    public async leaseNTasks(queue: string, limit: number, worker: string, taskTimeOutInSecs?: number): Promise<Task[]> {
-      let response = await this.scyllaManager.leaseNTasks(queue, limit, worker, taskTimeOutInSecs);
-      return JSON.parse(response);
-    }
+  public async leaseNTasks(queue: string, limit: number, worker: string, taskTimeOutInSecs?: number): Promise<Task[]> {
+    let response = await this.scyllaManager.leaseNTasks(queue, limit, worker, taskTimeOutInSecs);
+    return JSON.parse(response);
+  }
 
   public async heartBeatTask(rn: string, worker: string, progress?: number, taskTimeOutInSecs?: number): Promise<Task> {
     let response = await this.scyllaManager.heartBeatTask(rn, worker, progress, taskTimeOutInSecs);
@@ -126,10 +128,10 @@ class Scylla {
   }
 
   public async abortTask(rn: string, taskError: TaskError): Promise<Task> {
-    if (!taskError || !taskError.args){
-      throw Error ( "Invalid argument. taskError.args cannot be undefined" );
+    if (!taskError || !taskError.args) {
+      throw Error("Invalid argument. taskError.args cannot be undefined");
     }
-    let response = await this.scyllaManager.abortTask(rn, {...taskError, args: JSON.stringify(taskError.args)});
+    let response = await this.scyllaManager.abortTask(rn, { ...taskError, args: JSON.stringify(taskError.args) });
     return JSON.parse(response);
   }
 }