Skip to content

Hourly tests

Hourly tests #23233

Workflow file for this run

name: Hourly tests
permissions:
contents: read
concurrency:
group: hourly-${{ github.ref }}
cancel-in-progress: true
on:
schedule:
- cron: "0 */2 * * *"
# pull_request:
# branches: [master]
workflow_dispatch:
env:
CARGO_TERM_COLOR: always
K3D_VERSION: v5.4.1
FLV_CLUSTER_PROVISION_TIMEOUT: 600
jobs:
build_long_binaries:
name: Test build for ${{ matrix.binary }} on (${{ matrix.os }})
if: ${{ false }}
runs-on: ${{ matrix.os }}
strategy:
matrix:
rust-target:
- x86_64-unknown-linux-musl
rust: [stable]
binary: [fluvio-test]
os: [ubuntu-latest]
env:
RUST_BACKTRACE: full
RUSTV: ${{ matrix.rust }}
TARGET: ${{ matrix.rust-target }}
RUST_BIN_DIR: target/${{ matrix.rust-target }}/release
RELEASE_NAME: release
RELEASE: true
steps:
- uses: actions/checkout@v4
- name: Install Rust ${{ matrix.rust }} Toolchain
uses: dtolnay/rust-toolchain@master
with:
toolchain: ${{ matrix.rust }}
- name: Install zig
run: ./actions/zig-install.sh ${{ matrix.os }}
- uses: Swatinem/rust-cache@v2
with:
key: ${{ matrix.os }}-${{ env.RUST_BIN_DIR }}-${{ matrix.binary }}
- name: Build fluvio
if: matrix.binary == 'fluvio'
run: make build-cli
- name: Build fluvio-run
if: matrix.binary == 'fluvio-run'
run: make build-cluster
- name: Build fluvio-test
if: matrix.binary == 'fluvio-test'
run: make build-test
# Upload artifacts
- name: Upload artifact - ${{ matrix.binary }}
uses: actions/upload-artifact@v4
with:
name: ${{ matrix.binary }}-${{ matrix.rust-target }}
path: ${{ env.RUST_BIN_DIR }}/${{ matrix.binary }}
longevity:
name: Hourly Longevity test
runs-on: ${{ matrix.os }}
# needs:
# - build_long_binaries
timeout-minutes: 120
strategy:
fail-fast: false
matrix:
os: [ubuntu-latest]
rust-target: [x86_64-unknown-linux-musl]
run: [r1]
# run: [r1,r2,r3,r4,r5,r6,r7,r8,r9]
binary: [dev]
test_run_time: [30m]
producer: [1, 25]
producer_record_bytes: [2000] # 2KB
producer_batch_bytes: [10000] # 10KB
producer_linger_ms: [10]
consumer: [1, 25]
topic: [1, 10]
topic_segment_bytes: [500000] # 500KB
topic_retention: [15s]
cluster_type: [local,k8]
env:
TEST_BINARY: fluvio-test-x86_64-unknown-linux-musl
steps:
- uses: actions/checkout@v4
- name: Login GH CLI
# if: ${{ false }}
run: gh auth login --with-token < <(echo ${{ secrets.GITHUB_TOKEN }})
- name: Download dev release
# if: ${{ false }}
run: gh release download dev -R infinyon/fluvio -D /tmp/release
- name: Unpack fluvio-test from dev release
# if: ${{ false }}
run: |
cd /tmp/release; unzip ${{ env.TEST_BINARY }}.zip; chmod +x fluvio-test
echo "/tmp/release" >> $GITHUB_PATH
- name: Download build artifact - fluvio-test
if: ${{ false }}
uses: actions/download-artifact@v4
with:
name: fluvio-test-${{ matrix.rust-target }}
path: ~/bin
- name: Set up Fluvio binaries from build
if: ${{ false }}
run: |
chmod +x ~/bin/fluvio-test
echo "~/bin" >> $GITHUB_PATH
## DEBUG: Don't forget to remove this
## TODO: Figure out how to add this to the hourly test
#- name: Delete Artifact by Name
# uses: jimschubert/delete-artifacts-action@v1
# with:
# log_level: 'debug'
# artifact_name: longevity-data
# dry_run: false
# TODO: Test optimization
# We want to check for certain conditions for when to run this test
# Check if the cached git commit matches the current git commit
# If the match, then we've already run a test on this build. Skip this run
# If they don't match, then let's run the test
- name: Setup K3d
if: ${{ matrix.cluster_type == 'k8' }}
run: curl -s https://raw.githubusercontent.com/rancher/k3d/main/install.sh | TAG=${{ env.K3D_VERSION }} bash
- name: Create K3d cluster
if: ${{ matrix.cluster_type == 'k8' }}
run: |
./k8-util/cluster/reset-k3d.sh
- name: Setup Fluvio
uses: infinyon/fluvio/.github/actions/setup-fluvio@master
with:
version: latest
- name: Start Fluvio Cluster
# --image-version is only used in the k8 cluster_type
run: |
fluvio version
fluvio cluster start --${{ matrix.cluster_type}} --image-version latest
# Disabled for now bc data load is unstable in CI
#- name: Look for longevity data
# run: |
# set -e
# if gh run download -n longevity-data -D /tmp ; then
# echo "Longevity data exists"
# cd /tmp
# tar -xvf longevity-data.tar
# ~/.fluvio/bin/fluvio topic create test
# kubectl cp longevity-existing-0/00000000000000000000.index fluvio-spg-main-0:var/lib/fluvio/data/spu-logs-0/test-0/00000000000000000000.index
# kubectl cp longevity-existing-0/00000000000000000000.log fluvio-spg-main-0:var/lib/fluvio/data/spu-logs-0/test-0/00000000000000000000.log
# kubectl cp longevity-existing-0/replication.chk fluvio-spg-main-0:var/lib/fluvio/data/spu-logs-0/test-0/replication.chk
# k3d cluster stop --all
# k3d cluster start --all
# sleep 30
# else
# echo "Longevity data does not exist"
# fi
- name: Run longevity test
timeout-minutes: 65
run: |
sleep 10
RUST_LOG=info fluvio-test \
--timeout=${{ matrix.test_run_time }} \
--producer ${{ matrix.producer }} \
--producer-record-size ${{ matrix.producer_record_bytes }} \
--producer-batch-size ${{ matrix.producer_batch_bytes }} \
--producer-linger ${{ matrix.producer_linger_ms }} \
--consumer ${{ matrix.consumer }} \
--topic ${{ matrix.topic }} \
--topic-segment-size ${{ matrix.topic_segment_bytes }} \
--topic-retention ${{ matrix.topic_retention }} \
--expect-timeout \
longevity
## If the test passed, then copy the data from cluster to store into artifacts
#- name: Export data from the cluster for caching
# run: |
# kubectl version
# mkdir longevity-0
# echo Copy fluvio topic data from container
# kubectl cp fluvio-spg-main-0:/var/lib/fluvio/data/spu-logs-0/longevity-0 longevity-0
# ls
# echo List copied topic data
# ls longevity-0
# echo Make tarball from topic data
# tar -cvf longevity-data.tar longevity-0
# echo Verify tarball
# cp longevity-data.tar /tmp
# cd /tmp
# tar -xvf longevity-data.tar
## TODO: Add a shorter cache time
#- uses: actions/upload-artifact@v4
# with:
# name: 'longevity-data'
# path: longevity-data.tar
# retention-days: 5
- name: Run diagnostics
if: failure()
timeout-minutes: 5
run: fluvio cluster diagnostics
- name: Upload diagnostics
uses: actions/upload-artifact@v4
timeout-minutes: 5
if: failure()
with:
name: hourly-longevity-${{ matrix.run }}.diag
path: diagnostics*.gz
- name: Slack Notification
uses: 8398a7/action-slack@v3
if: ${{ !success() }}
with:
status: ${{ job.status }}
fields: repo,message,commit,author,action,eventName,ref,workflow,job
env:
SLACK_WEBHOOK_URL: ${{ secrets.SLACK_WEBHOOK_URL }}
MATRIX_CONTEXT: ${{ toJson(matrix) }}