forked from feldera/feldera
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathMakefile.toml
69 lines (62 loc) · 1.67 KB
/
Makefile.toml
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
[env]
RUST_BUILD_PROFILE = "--release"
[tasks.build]
command = "cargo"
args = ["build", "--features=pg-embed", "@@remove-empty(RUST_BUILD_PROFILE)"]
[tasks.openapi_json]
description = "Dump OpenAPI specification of the REST API to 'openapi.json'"
dependencies = ["build"]
cwd = "../../"
command = "cargo"
args = [
"run",
"--package",
"pipeline-manager",
"--features=pg-embed",
"--bin",
"pipeline-manager",
"${RUST_BUILD_PROFILE}",
"--",
"--dump-openapi",
]
[tasks.start_manager]
script = '''
old_manager_pid=$(pgrep "pipeline-mana" || echo "")
echo "Old manager: " $old_manager_pid
if [ -n "$old_manager_pid" ]; then
echo "Previous manager instance is running"
exit 1
fi
../../scripts/start_manager.sh &
manager_pid=$!
while true; do
if curl --output /dev/null --silent --head --fail http://localhost:8080; then
echo "Pipeline manager is up and running"
break
else
if ! ps -p $manager_pid > /dev/null; then
echo "Manager process has terminated unexpectedly"
exit 1
fi
sleep 1
fi
done
'''
[tasks.python_api_test]
description = "Test Python API"
dependencies = [ "start_manager"]
script = '''
python3 ../../demo/simple-join/run.py --api-url http://localhost:8080 --connector-type http
'''
[tasks.fraud_notebook_test]
description = "Fraud detection Python notebook test"
dependencies = ["start_manager"]
script = '''
cd ../../demo/demo_notebooks
pip3 install -r requirements.txt
IN_CI=1 jupyter execute fraud_detection.ipynb --JupyterApp.log_level='DEBUG'
'''
[tasks.python_test]
dependencies = ["fraud_notebook_test", "python_api_test"]
[tasks.test]
dependencies = ["python_test"]