dataflow.yml

communication:
  zenoh:
    prefix: /foo

nodes:
  - id: sender
    custom:
      run: cargo run --bin sender --release
      env:
        CONCURRENCIES: 10
        ITERATIONS: 2
        WAIT_ITERATIONS_IN_SECS: 2
      outputs:
        - image
        - context
      inputs:
        mounted_0: tokio_spawn_blocking/mounted
        mounted_1: rayon_spawn/mounted
  - id: rayon_spawn
    custom:
      run: cargo run --bin rayon_spawn --release
      inputs:
        image: sender/image
        context: sender/context
      outputs:
        - mounted
      env:
        RAYON_NUM_THREADS: 5
        NUMBER_OF_CALLS: 22
  - id: tokio_spawn_blocking
    custom:
      run: cargo run --bin tokio_spawn_blocking --release
      # run: flamegraph -o tokio_spawn_blocking.svg -- ./target/release/tokio_spawn_blocking
      env:
        TOKIO_BLOCKING_THREADS: 50
        TOKIO_WORKER_THREADS: 1
        NUMBER_OF_CALLS: 22
      inputs:
        image: sender/image
        context: sender/context
      outputs:
        - mounted