From 15a314253073611b595eb3d8929049e5dd08bd3e Mon Sep 17 00:00:00 2001 From: Gheorghe Teodor Bercea Date: Fri, 3 Sep 2021 13:49:35 -0400 Subject: [PATCH 1/2] Re-enable all tests. --- .travis.yml | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/.travis.yml b/.travis.yml index 9142a52..f71b8b2 100644 --- a/.travis.yml +++ b/.travis.yml @@ -31,10 +31,10 @@ script: - ./scripts/start-kind.sh # Test local container run mode - # - RAYVENS_TEST_MODE=local python ./tests/stream.py - # - RAYVENS_TEST_MODE=local python ./tests/source.py + - RAYVENS_TEST_MODE=local python ./tests/stream.py + - RAYVENS_TEST_MODE=local python ./tests/source.py - RAYVENS_TEST_MODE=local RAYVENS_TRANSPORT=kafka python ./tests/source.py - # - ray submit ./scripts/cluster.yaml ./tests/stream.py + - ray submit ./scripts/cluster.yaml ./tests/stream.py - ray submit ./scripts/cluster.yaml ./tests/source.py - RAYVENS_TEST_MODE=local python ./tests/kafka_transport.py - ray submit ./scripts/cluster.yaml ./tests/kafka_transport.py local @@ -42,15 +42,15 @@ script: - ray submit ./scripts/cluster.yaml ./tests/kafka_scaling_transport.py local # Test operator mode - # - ray submit ./scripts/cluster.yaml ./tests/source_operator.py + - ray submit ./scripts/cluster.yaml ./tests/source_operator.py - RAYVENS_TEST_MODE=local python ./tests/sink.py - ray submit ./scripts/cluster.yaml ./tests/sink.py - # - RAYVENS_TEST_MODE=local python ./tests/kafka.py - # - ray submit ./scripts/cluster.yaml ./tests/kafka.py - # - RAYVENS_TEST_MODE=local python ./tests/generic_sink.py - # - ray submit ./scripts/cluster.yaml ./tests/generic_sink.py - # - RAYVENS_TEST_MODE=local python ./tests/generic_source.py - # - ray submit ./scripts/cluster.yaml ./tests/generic_source.py + - RAYVENS_TEST_MODE=local python ./tests/kafka.py + - ray submit ./scripts/cluster.yaml ./tests/kafka.py + - RAYVENS_TEST_MODE=local python ./tests/generic_sink.py + - ray submit ./scripts/cluster.yaml ./tests/generic_sink.py + - RAYVENS_TEST_MODE=local python ./tests/generic_source.py + - ray submit ./scripts/cluster.yaml ./tests/generic_source.py - ray submit ./scripts/cluster.yaml ./tests/kafka_transport.py operator - ray submit ./scripts/cluster.yaml ./tests/kafka_scaling_transport.py operator From 25f1cc88c8fa00c8e231a6d95fbe144e331951e2 Mon Sep 17 00:00:00 2001 From: Gheorghe Teodor Bercea Date: Fri, 3 Sep 2021 13:52:52 -0400 Subject: [PATCH 2/2] Fix comment. --- examples/kafka/kafka_event_streaming_source.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/examples/kafka/kafka_event_streaming_source.py b/examples/kafka/kafka_event_streaming_source.py index f0f99be..47c3949 100644 --- a/examples/kafka/kafka_event_streaming_source.py +++ b/examples/kafka/kafka_event_streaming_source.py @@ -56,7 +56,7 @@ # Log all events from stream-attached sources. stream >> (lambda event: print('LOG:', event)) -# Event source config. +# Event source configuration. source_config = dict( kind='http-source', url='https://query1.finance.yahoo.com/v7/finance/quote?symbols=AAPL',