Skip to content

Commit

Permalink
Add todo
Browse files Browse the repository at this point in the history
  • Loading branch information
CeEv committed Dec 5, 2024
1 parent b94bccd commit 1fc05d4
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/modules/worker/worker.service.ts
Original file line number Diff line number Diff line change
Expand Up @@ -41,9 +41,9 @@ export class WorkerService implements OnModuleInit, Job {
this.stop();
});
/**
* The promise ist started without await as seperate handled promise chain.
* The promise is started without await as seperate handled promise chain.
*/
this.start(this.config.WORKER_IDLE_BREAK_MS);
this.start(this.config.WORKER_IDLE_BREAK_MS); // TODO BREAK -> PAUSE
}

public async start(idleBreakTimeInMs = 1): Promise<void> {
Expand Down Expand Up @@ -86,7 +86,7 @@ export class WorkerService implements OnModuleInit, Job {
// Promise all?
const deletedDocEntries = await this.redis.getDeletedDocEntries();
const streamLength = await this.redis.tryClearTask(task);
const roomStreamInfos = decodeRedisRoomStreamName(task.stream.toString(), this.redis.redisPrefix); // TODO + Naming
const roomStreamInfos = decodeRedisRoomStreamName(task.stream.toString(), this.redis.redisPrefix); // TODO

if (this.streamIsEmpty(streamLength)) {
this.removingRecurringTaskFromQueue(task, deletedDocEntries, roomStreamInfos);
Expand Down

0 comments on commit 1fc05d4

Please sign in to comment.