action-queue-consumer.ts

class ActionGenerate {
  ....
  workDone() {
    return this.props.workDone;
  }

  workToDo(): IPromptParam[] {
     const notDone: IPromptParam[] = [];
     for (const r of this.props.resource){
       if (state.skipped < this.props.workDone) { 
         state += r.n_iter 
       }
       notDone.push(r)
     }
  }
                                               
  async updateProgress(progressDone: number): Promise<void> {
    const resp = await this.dynamoClient(updateComand)
    if (resp.prioScore != this.props.prioScore) { 
      await this.updateStatus('pending');
      throw new JobReprioritized(...)
    }
    if (resp.currentStatus != 'running') { throw new JobCancelled }
  }

  async process(param: IPromptParam) {
    ...stuffs
    await this.updateProgress(this.workDone + param.n_iter)
  }
  
  async processAll() {
     await this.updateStatus('running');
     const todos = this.workToDo();
     for (const todo of todos) {
        const resp = await this.process(todo).catch((e) => e);
        if (resp instanceof JobReprioritized) { return; }
        if (resp instanceof Error) { break; }
     }
     await this.updateStatus('completed');
  }
}