Skip to content

Commit 0f4c0b4

Browse files
snkassnkas
committed
pipeline-manager: move packaged demos
This moves the most important demos (the packaged ones), which is in preparation of cleaning up the other demos. Signed-off-by: Simon Kassing <simon.kassing@feldera.com>
1 parent d5a9055 commit 0f4c0b4

29 files changed

Lines changed: 27 additions & 45 deletions

‎.github/workflows/test-integration-platform.yml‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -209,8 +209,8 @@ jobs:
209209
- name: Validate and run packaged demos
210210
if: ${{ vars.CI_DRY_RUN != 'true' }}
211211
run: |
212-
(cd demo/packaged && uv run validate-preamble.py sql/*.sql)
213-
uv run demo/all-packaged/run.py --api-url http://localhost:8080
212+
(cd crates/pipeline-manager/demos && uv run validate-preamble.py sql/*.sql)
213+
uv run crates/pipeline-manager/demos/run.py --api-url http://localhost:8080
214214
env:
215215
PYTHONPATH: ${{ github.workspace }}/python
216216
FELDERA_HTTPS_TLS_CERT: ../test-tls/tls_test.crt

‎CLAUDE.md‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9858,7 +9858,7 @@ The token caching system is designed to work across multiple processes:
98589858

98599859
This pattern is used by:
98609860
- **Pytest Test Runs**: Master node fetches token, workers reuse it
9861-
- **Demo Runners**: `demo/all-packaged/run.py` uses the same caching mechanism
9861+
- **Demo Runners**: `crates/pipeline-manager/demos/run.py` uses the same caching mechanism
98629862
- **CI Workflows**: Multiple demos in sequence reuse the same token
98639863
<!-- SECTION:python/tests/CLAUDE.md END -->
98649864

demo/packaged/README.md renamed to crates/pipeline-manager/demos/README.md

Lines changed: 5 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -8,21 +8,18 @@ All the SQL files in `sql/` are packaged demos with every Feldera release.
88

99
- **Preamble validation:**
1010
```bash
11-
python3 validate-preamble.py sql/*.sql
11+
uv run validate-preamble.py sql/*.sql
1212
```
1313

14-
- **Cargo run with demos:**
14+
- **Specify specific demos directory:**
1515
```bash
1616
cargo run --bin pipeline-manager \
17-
-- --demos-dir demo/packaged/sql
17+
-- --demos-dir crates/pipeline-manager/demos/sql
1818
```
1919

20-
- **Docker:** in the Dockerfile, directory `demo/packaged/sql` was copied over to
21-
`/home/feldera/demos`, and `--demos-dir /home/feldera/demos` has been added to
22-
the entry point command. Bring it up for example with:
20+
- **Run all demos packaged on the Feldera instance:**
2321
```bash
24-
docker compose -f deploy/docker-compose.yml \
25-
-f deploy/docker-compose-dev.yml up --build
22+
uv run run.py --api-url http://localhost:8080
2623
```
2724

2825
## Specification

demo/all-packaged/run.py renamed to crates/pipeline-manager/demos/run.py

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -8,9 +8,6 @@
88

99
#!/bin/python3
1010

11-
# Run locally with:
12-
# uv run demo/all-packaged/run.py --api-url http://localhost:8080
13-
1411
import time
1512
import requests
1613
import argparse
@@ -65,9 +62,9 @@ def main():
6562
pipeline.start()
6663
time.sleep(2)
6764
status = pipeline.status()
68-
assert status == PipelineStatus.RUNNING, f"FAIL: demo {
69-
demo['name']
70-
}: expected pipeline to be RUNNING but instead is {status}"
65+
assert status == PipelineStatus.RUNNING, (
66+
f"""FAIL: demo {demo["name"]}: expected pipeline to be RUNNING but instead is {status}"""
67+
)
7168
pipeline.stop(force=True)
7269
print(f"PASS: demo {demo['name']}")
7370

demo/packaged/sql/00-accelerating-batch-analytics.sql renamed to crates/pipeline-manager/demos/sql/00-accelerating-batch-analytics.sql

File renamed without changes.

demo/packaged/sql/01-fraud-detection.sql renamed to crates/pipeline-manager/demos/sql/01-fraud-detection.sql

File renamed without changes.

demo/packaged/sql/02-sec-ops.sql renamed to crates/pipeline-manager/demos/sql/02-sec-ops.sql

File renamed without changes.

demo/packaged/sql/03-product-availability.sql renamed to crates/pipeline-manager/demos/sql/03-product-availability.sql

File renamed without changes.

demo/packaged/sql/04-feature-engineering.sql renamed to crates/pipeline-manager/demos/sql/04-feature-engineering.sql

File renamed without changes.

demo/packaged/sql/05-supply-chain.sql renamed to crates/pipeline-manager/demos/sql/05-supply-chain.sql

File renamed without changes.

0 commit comments

Comments
 (0)