Skip to content

Commit

Permalink
Adding helm option to k8s_cluster.py example
Browse files Browse the repository at this point in the history
  • Loading branch information
miccioest committed Mar 22, 2024
1 parent bf79af6 commit 47710eb
Showing 1 changed file with 12 additions and 2 deletions.
14 changes: 12 additions & 2 deletions charts/bytewax/examples/k8s_cluster.py
Original file line number Diff line number Diff line change
Expand Up @@ -39,15 +39,25 @@ def to_tuple(x):
# flow.output("out", DirOutput(output_dir, 5, assign_file=int))


# We are going to use Waxctl, you can download it from https://bytewax.io/downloads
# Run these commands in your terminal to run a cluster of two containers:
# To run this example using helm you need to run the following
# helm upgrade --install k8s-cluster \
# bytewax/bytewax \
# --set configuration.pythonFileName=k8s_cluster.py \
# --set configuration.processesCount=2 \
# --set configuration.configMap.files.tarName=examples.tar \
# --set configuration.keepAlive=true

# Also, you could use Waxctl to run the example. For that you can download it from https://bytewax.io/downloads
# And then, run these commands in your terminal to run a cluster of two containers:

# $ tar -C ./ -cvf cluster.tar examples
# $ waxctl dataflow deploy ./cluster.tar \
# --name k8s-cluster \
# --python-file-name examples/k8s_cluster.py \
# -p2 --debug --keep-alive=true --yes

# Regardless of how you have executed the example (helm CLI or waxctl):

# Each worker will read the files in
# ./examples/sample_data/cluster/*.txt which have lines like
# `ONE1`.
Expand Down

0 comments on commit 47710eb

Please sign in to comment.