Update to Camel-K 1.5.0 (#11)

* Update to Camel-K 1.5.0.

* Fix end condition

* Add timer before sending a message.

Author: doru1004

Dockerfile

@@ -17,7 +17,7 @@
 ARG base_image=rayproject/ray:1.4.1-py38
 FROM ${base_image}
 
-COPY --from=docker.io/apache/camel-k:1.4.0 /usr/local/bin/kamel /usr/local/bin/
+COPY --from=docker.io/apache/camel-k:1.5.0 /usr/local/bin/kamel /usr/local/bin/
 
 RUN sudo apt-get update \
     && sudo apt-get install -y --no-install-recommends openjdk-11-jdk maven \

Dockerfile.release

@@ -17,7 +17,7 @@
 ARG base_image=rayproject/ray:1.4.1-py38
 FROM ${base_image}
 
-COPY --from=docker.io/apache/camel-k:1.4.0 /usr/local/bin/kamel /usr/local/bin/
+COPY --from=docker.io/apache/camel-k:1.5.0 /usr/local/bin/kamel /usr/local/bin/
 
 RUN sudo apt-get update \
     && sudo apt-get install -y --no-install-recommends openjdk-11-jdk maven \

examples/slack/slack_operator_mode.py

@@ -55,6 +55,8 @@
 # Wait for sink to reach running state.
 ray.get(sink)
 
+time.sleep(15)
+
 # Sends message to all sinks attached to this stream.
 stream << f'Sending message to Slack sink in run mode {run_mode}.'
 

rayvens/core/kamel_utils.py

@@ -76,7 +76,7 @@ def kamel_command_end_condition(subcommand_type, base_name):
     if subcommand_type == KamelCommand.BUILD:
         return ""
     if subcommand_type == KamelCommand.RUN:
-        return f"integration \"{base_name}\""
+        return f"Integration \"{base_name}\""
     if subcommand_type == KamelCommand.LOCAL_BUILD:
         return ""
     if subcommand_type == KamelCommand.LOCAL_RUN:

scripts/rayvens-setup.sh

@@ -569,7 +569,7 @@ if [ -n "$kamel" ]; then
     echo "--- installing Kamel operator"
     kubectl create serviceaccount kamel -n "$namespace"
     kubectl create clusterrolebinding kamel --clusterrole=cluster-admin --serviceaccount="$namespace":kamel
-    kubectl run --rm -i -t kamel --image=apache/camel-k:1.4.0 --restart=Never --serviceaccount=kamel -n "$namespace" -- \
+    kubectl run --rm -i -t kamel --image=apache/camel-k:1.5.0 --restart=Never --serviceaccount=kamel -n "$namespace" -- \
         kamel install --force $(echo "$options")
     kubectl delete clusterrolebinding kamel
     kubectl delete serviceaccount kamel -n "$namespace"

scripts/start-kind.sh

@@ -37,7 +37,7 @@ kubectl apply -n ray -f kafka.yaml
 echo "--- installing kamel operator"
 kubectl create serviceaccount kamel -n ray
 kubectl create clusterrolebinding kamel --clusterrole=cluster-admin --serviceaccount=ray:kamel
-kubectl run --rm -i -t kamel --image=apache/camel-k:1.4.0 --restart=Never --serviceaccount=kamel -n ray -- \
+kubectl run --rm -i -t kamel --image=apache/camel-k:1.5.0 --restart=Never --serviceaccount=kamel -n ray -- \
     kamel install --registry-insecure --namespace ray --registry registry:5000
 kubectl delete clusterrolebinding kamel
 kubectl delete serviceaccount kamel -n ray

scripts/travis.sh

@@ -16,7 +16,7 @@
 
 set -eu
 
-KAMEL_VERSION=v1.4.0
+KAMEL_VERSION=v1.5.0
 KIND_VERSION=v0.10.0
 KUBECTL_VERSION=v1.18.8