diff --git a/scylla_pg_client/index.ts b/scylla_pg_client/index.ts index 8612ad5..6c3f15d 100644 --- 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 { - 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 { + 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 { - 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 { + 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 { let response = await this.scyllaManager.heartBeatTask(rn, worker, progress, taskTimeOutInSecs); @@ -126,10 +128,10 @@ class Scylla { } public async abortTask(rn: string, taskError: TaskError): Promise { - 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); } }