Allow users to specify none to remove transformation (#8579)

`wrangler pipelines update <name> --transforms none`

Fixes https://jira.cfdata.org/browse/PIPE-232

Author: cmackenzie1

.changeset/warm-forks-visit.md

@@ -0,0 +1,5 @@
+---
+"wrangler": patch
+---
+
+Allow `wrangler pipelines update <pipelineName> --transform-worker none` to remove transformations from a Pipeline.

packages/wrangler/src/__tests__/pipelines.test.ts

@@ -601,6 +601,25 @@ describe("pipelines", () => {
 			`);
 			expect(requests.count).toEqual(1);
 		});
+
+		it("should remove transformations", async () => {
+			const pipeline: Pipeline = samplePipeline;
+			mockShowRequest(pipeline.name, pipeline);
+
+			const update = JSON.parse(JSON.stringify(pipeline));
+			update.transforms = [
+				{
+					script: "hello",
+					entrypoint: "MyTransform",
+				},
+			];
+			const updateReq = mockUpdateRequest(update.name, update);
+
+			await runWrangler("pipelines update my-pipeline --transform-worker none");
+
+			expect(updateReq.count).toEqual(1);
+			expect(updateReq.body?.transforms.length).toEqual(0);
+		});
 	});
 
 	describe("delete", () => {

packages/wrangler/src/pipelines/cli/update.ts

@@ -104,7 +104,7 @@ export function addUpdateOptions(yargs: Argv<CommonYargsOptions>) {
 			.option("transform-worker", {
 				type: "string",
 				describe:
-					"Pipeline transform Worker and entrypoint (<worker>.<entrypoint>)",
+					'Pipeline transform Worker and entrypoint, to transform ingested records. Specified as <worker-name>.<entrypoint>, or "none".',
 				demandOption: false,
 			})
 
@@ -282,7 +282,12 @@ export async function updatePipelineHandler(
 	}
 
 	if (args.transformWorker) {
-		pipelineConfig.transforms.push(parseTransform(args.transformWorker));
+		if (args.transformWorker === "none") {
+			// Unset transformations
+			pipelineConfig.transforms = [];
+		} else {
+			pipelineConfig.transforms.push(parseTransform(args.transformWorker));
+		}
 	}
 
 	if (args.r2Prefix) {