feat: workers now checks for disabled actions

This commit is contained in:
Zoe Roux
2022-03-01 14:25:16 +01:00
parent 72c3c473b2
commit e60c89d419
+2 -1
View File
@@ -1,4 +1,4 @@
import { catchError, groupBy, lastValueFrom, map, mergeMap, NEVER, Observable, switchAll, tap } from "rxjs";
import { catchError, filter, groupBy, lastValueFrom, map, mergeMap, NEVER, Observable, switchAll, tap } from "rxjs";
import { BaseService } from "./models/base-service";
import { Pipeline, PipelineEnv, PipelineType } from "./models/pipeline";
import { Runner } from "./runner";
@@ -14,6 +14,7 @@ export class Manager {
async run(): Promise<void> {
await lastValueFrom(this._pipelines
.pipe(
filter(x => x.enabled),
groupBy((x: Pipeline) => x.id),
switchAll(),
mergeMap((x: Pipeline) =>