Skip to content

Commit ea586a2

Browse files
committed
Add Cloudflare Pipelines commands
1 parent a8cac0f commit ea586a2

File tree

12 files changed

+1286
-11
lines changed

12 files changed

+1286
-11
lines changed

.changeset/polite-tigers-end.md

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
---
2+
"wrangler": minor
3+
---
4+
5+
feature: Integrate the Cloudflare Pipelines product into wrangler.
6+
7+
Cloudflare Pipelines is a product that handles the ingest of event streams
8+
into R2. This feature integrates various forms of managing pipelines.
9+
10+
Usage:
11+
wrangler pipelines create <pipeline> Create a new pipeline
12+
wrangler pipelines list List current pipelines
13+
wrangler pipelines show <pipeline> Show a pipeline configuration
14+
wrangler pipelines update <pipeline> Update a pipeline
15+
wrangler pipelines delete <pipeline> Delete a pipeline
16+
17+
Examples:
18+
wrangler pipelines create my-pipeline --r2 MY_BUCKET --access-key-id "my-key" --secret-access-key "my-secret"
19+
wrangler pipelines show my-pipeline
20+
wrangler pipelines delete my-pipline

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

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@ describe("ai help", () => {
2121
2222
🤖 Manage AI models
2323
24-
2524
COMMANDS
2625
wrangler ai models List catalog models
2726
wrangler ai finetune Interact with finetune files
@@ -51,7 +50,6 @@ describe("ai help", () => {
5150
5251
🤖 Manage AI models
5352
54-
5553
COMMANDS
5654
wrangler ai models List catalog models
5755
wrangler ai finetune Interact with finetune files

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -383,7 +383,7 @@ describe("deploy", () => {
383383

384384
expect(std.out).toMatchInlineSnapshot(`
385385
"Attempting to login via OAuth...
386-
Opening a link in your default browser: https://dash.cloudflare.com/oauth2/auth?response_type=code&client_id=54d11594-84e4-41aa-b438-e81b8fa78ee7&redirect_uri=http%3A%2F%2Flocalhost%3A8976%2Foauth%2Fcallback&scope=account%3Aread%20user%3Aread%20workers%3Awrite%20workers_kv%3Awrite%20workers_routes%3Awrite%20workers_scripts%3Awrite%20workers_tail%3Aread%20d1%3Awrite%20pages%3Awrite%20zone%3Aread%20ssl_certs%3Awrite%20ai%3Awrite%20queues%3Awrite%20offline_access&state=MOCK_STATE_PARAM&code_challenge=MOCK_CODE_CHALLENGE&code_challenge_method=S256
386+
Opening a link in your default browser: https://dash.cloudflare.com/oauth2/auth?response_type=code&client_id=54d11594-84e4-41aa-b438-e81b8fa78ee7&redirect_uri=http%3A%2F%2Flocalhost%3A8976%2Foauth%2Fcallback&scope=account%3Aread%20user%3Aread%20workers%3Awrite%20workers_kv%3Awrite%20workers_routes%3Awrite%20workers_scripts%3Awrite%20workers_tail%3Aread%20d1%3Awrite%20pages%3Awrite%20zone%3Aread%20ssl_certs%3Awrite%20ai%3Awrite%20queues%3Awrite%20pipelines%3Awrite%20offline_access&state=MOCK_STATE_PARAM&code_challenge=MOCK_CODE_CHALLENGE&code_challenge_method=S256
387387
Successfully logged in.
388388
Total Upload: xx KiB / gzip: xx KiB
389389
Worker Startup Time: 100 ms
@@ -424,7 +424,7 @@ describe("deploy", () => {
424424

425425
expect(std.out).toMatchInlineSnapshot(`
426426
"Attempting to login via OAuth...
427-
Opening a link in your default browser: https://dash.staging.cloudflare.com/oauth2/auth?response_type=code&client_id=54d11594-84e4-41aa-b438-e81b8fa78ee7&redirect_uri=http%3A%2F%2Flocalhost%3A8976%2Foauth%2Fcallback&scope=account%3Aread%20user%3Aread%20workers%3Awrite%20workers_kv%3Awrite%20workers_routes%3Awrite%20workers_scripts%3Awrite%20workers_tail%3Aread%20d1%3Awrite%20pages%3Awrite%20zone%3Aread%20ssl_certs%3Awrite%20ai%3Awrite%20queues%3Awrite%20offline_access&state=MOCK_STATE_PARAM&code_challenge=MOCK_CODE_CHALLENGE&code_challenge_method=S256
427+
Opening a link in your default browser: https://dash.staging.cloudflare.com/oauth2/auth?response_type=code&client_id=54d11594-84e4-41aa-b438-e81b8fa78ee7&redirect_uri=http%3A%2F%2Flocalhost%3A8976%2Foauth%2Fcallback&scope=account%3Aread%20user%3Aread%20workers%3Awrite%20workers_kv%3Awrite%20workers_routes%3Awrite%20workers_scripts%3Awrite%20workers_tail%3Aread%20d1%3Awrite%20pages%3Awrite%20zone%3Aread%20ssl_certs%3Awrite%20ai%3Awrite%20queues%3Awrite%20pipelines%3Awrite%20offline_access&state=MOCK_STATE_PARAM&code_challenge=MOCK_CODE_CHALLENGE&code_challenge_method=S256
428428
Successfully logged in.
429429
Total Upload: xx KiB / gzip: xx KiB
430430
Worker Startup Time: 100 ms

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@ describe("wrangler", () => {
6161
wrangler pubsub 📮 Manage Pub/Sub brokers [private beta]
6262
wrangler dispatch-namespace 🏗️ Manage dispatch namespaces
6363
wrangler ai 🤖 Manage AI models
64+
wrangler pipelines 🚰 Manage Worker Pipelines
6465
6566
wrangler login 🔓 Login to Cloudflare
6667
wrangler logout 🚪 Logout from Cloudflare
@@ -118,6 +119,7 @@ describe("wrangler", () => {
118119
wrangler pubsub 📮 Manage Pub/Sub brokers [private beta]
119120
wrangler dispatch-namespace 🏗️ Manage dispatch namespaces
120121
wrangler ai 🤖 Manage AI models
122+
wrangler pipelines 🚰 Manage Worker Pipelines
121123
122124
wrangler login 🔓 Login to Cloudflare
123125
wrangler logout 🚪 Logout from Cloudflare

0 commit comments

Comments
 (0)