From e60c89d419dc780746af1be221357b0774d6902e Mon Sep 17 00:00:00 2001
From: Zoe Roux <zoe.roux@sdg.moe>
Date: Tue, 1 Mar 2022 14:25:16 +0100
Subject: [PATCH] feat: workers now checks for disabled actions

---
 worker/src/actions.ts | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/worker/src/actions.ts b/worker/src/actions.ts
index cc82141..856be74 100644
--- a/worker/src/actions.ts
+++ b/worker/src/actions.ts
@@ -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) =>