@@ -31,26 +31,26 @@ script:
31
31
- ./scripts/start-kind.sh
32
32
33
33
# Test local container run mode
34
- # - RAYVENS_TEST_MODE=local python ./tests/stream.py
35
- # - RAYVENS_TEST_MODE=local python ./tests/source.py
34
+ - RAYVENS_TEST_MODE=local python ./tests/stream.py
35
+ - RAYVENS_TEST_MODE=local python ./tests/source.py
36
36
- RAYVENS_TEST_MODE=local RAYVENS_TRANSPORT=kafka python ./tests/source.py
37
- # - ray submit ./scripts/cluster.yaml ./tests/stream.py
37
+ - ray submit ./scripts/cluster.yaml ./tests/stream.py
38
38
- ray submit ./scripts/cluster.yaml ./tests/source.py
39
39
- RAYVENS_TEST_MODE=local python ./tests/kafka_transport.py
40
40
- ray submit ./scripts/cluster.yaml ./tests/kafka_transport.py local
41
41
- RAYVENS_TEST_MODE=local python ./tests/kafka_scaling_transport.py
42
42
- ray submit ./scripts/cluster.yaml ./tests/kafka_scaling_transport.py local
43
43
44
44
# Test operator mode
45
- # - ray submit ./scripts/cluster.yaml ./tests/source_operator.py
45
+ - ray submit ./scripts/cluster.yaml ./tests/source_operator.py
46
46
- RAYVENS_TEST_MODE=local python ./tests/sink.py
47
47
- ray submit ./scripts/cluster.yaml ./tests/sink.py
48
- # - RAYVENS_TEST_MODE=local python ./tests/kafka.py
49
- # - ray submit ./scripts/cluster.yaml ./tests/kafka.py
50
- # - RAYVENS_TEST_MODE=local python ./tests/generic_sink.py
51
- # - ray submit ./scripts/cluster.yaml ./tests/generic_sink.py
52
- # - RAYVENS_TEST_MODE=local python ./tests/generic_source.py
53
- # - ray submit ./scripts/cluster.yaml ./tests/generic_source.py
48
+ - RAYVENS_TEST_MODE=local python ./tests/kafka.py
49
+ - ray submit ./scripts/cluster.yaml ./tests/kafka.py
50
+ - RAYVENS_TEST_MODE=local python ./tests/generic_sink.py
51
+ - ray submit ./scripts/cluster.yaml ./tests/generic_sink.py
52
+ - RAYVENS_TEST_MODE=local python ./tests/generic_source.py
53
+ - ray submit ./scripts/cluster.yaml ./tests/generic_source.py
54
54
- ray submit ./scripts/cluster.yaml ./tests/kafka_transport.py operator
55
55
- ray submit ./scripts/cluster.yaml ./tests/kafka_scaling_transport.py operator
56
56
0 commit comments