[INFO] cloning repository https://github.com/hydro-project/hydroflow
[INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/hydro-project/hydroflow" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fhydro-project%2Fhydroflow", kill_on_drop: false }`
[INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fhydro-project%2Fhydroflow'...
[INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }`
[INFO] [stdout] 9c9a27b42c9855ab9d725214b68d66c6c273da2b
[INFO] checking hydro-project/hydroflow against master#0d56e340472882fa673d4b98d0802b9a799879d0 for pr-101692
[INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fhydro-project%2Fhydroflow" "/workspace/builds/worker-3/source", kill_on_drop: false }`
[INFO] [stderr] Cloning into '/workspace/builds/worker-3/source'...
[INFO] [stderr] done.
[INFO] validating manifest of git repo https://github.com/hydro-project/hydroflow on toolchain 0d56e340472882fa673d4b98d0802b9a799879d0
[INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+0d56e340472882fa673d4b98d0802b9a799879d0" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] removed /workspace/builds/worker-3/source/.cargo/config.toml
[INFO] removed /workspace/builds/worker-3/source/rust-toolchain.toml
[INFO] started tweaking git repo https://github.com/hydro-project/hydroflow
[INFO] finished tweaking git repo https://github.com/hydro-project/hydroflow
[INFO] tweaked toml for git repo https://github.com/hydro-project/hydroflow written to /workspace/builds/worker-3/source/Cargo.toml
[INFO] crate git repo https://github.com/hydro-project/hydroflow already has a lockfile, it will not be regenerated
[INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+0d56e340472882fa673d4b98d0802b9a799879d0" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] [stderr]     Updating git repository `https://github.com/hydro-project/rust-sitter`
[INFO] [stderr]  Downloading crates ...
[INFO] [stderr]   Downloaded sealed v0.4.0
[INFO] [stderr]   Downloaded tree-sitter v0.20.8
[INFO] [stderr]   Downloaded smallbitvec v2.5.1
[INFO] [stderr]   Downloaded abomonation_derive v0.5.0
[INFO] [stderr]   Downloaded timely_logging v0.12.0
[INFO] [stderr]   Downloaded timely_bytes v0.12.0
[INFO] [stderr]   Downloaded timely_communication v0.12.0
[INFO] [stderr]   Downloaded tree-sitter-tags v0.20.2
[INFO] [stderr]   Downloaded timely v0.12.0
[INFO] [stderr]   Downloaded abomonation v0.7.3
[INFO] [stderr]   Downloaded tiny_http v0.8.2
[INFO] [stderr]   Downloaded tree-sitter-config v0.19.0
[INFO] [stderr]   Downloaded tree-sitter-highlight v0.20.1
[INFO] [stderr]   Downloaded datadriven v0.6.0
[INFO] [stderr]   Downloaded zipf v7.0.0
[INFO] [stderr]   Downloaded tree-sitter-loader v0.20.0
[INFO] [stderr]   Downloaded seq-macro v0.2.2
[INFO] [stderr]   Downloaded syn-inline-mod v0.5.0
[INFO] [stderr]   Downloaded xshell-macros v0.1.17
[INFO] [stderr]   Downloaded tuple_list v0.1.3
[INFO] [stderr]   Downloaded insta v1.19.0
[INFO] [stderr]   Downloaded xshell v0.1.17
[INFO] [stderr]   Downloaded tree-sitter-cli v0.20.6
[INFO] [stderr]   Downloaded differential-dataflow v0.12.0
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:824c28ce115f6b999260af6986f3384c158e782489540e41c0b698ca1d9fd927" "/opt/rustwide/cargo-home/bin/cargo" "+0d56e340472882fa673d4b98d0802b9a799879d0" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] ffe2bb526cf04cef1e3d1ea3cb7b8b2ae206a5ebafcc1dad95bdff3af553bf8e
[INFO] running `Command { std: "docker" "start" "-a" "ffe2bb526cf04cef1e3d1ea3cb7b8b2ae206a5ebafcc1dad95bdff3af553bf8e", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "ffe2bb526cf04cef1e3d1ea3cb7b8b2ae206a5ebafcc1dad95bdff3af553bf8e", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "ffe2bb526cf04cef1e3d1ea3cb7b8b2ae206a5ebafcc1dad95bdff3af553bf8e", kill_on_drop: false }`
[INFO] [stdout] ffe2bb526cf04cef1e3d1ea3cb7b8b2ae206a5ebafcc1dad95bdff3af553bf8e
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-3/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:824c28ce115f6b999260af6986f3384c158e782489540e41c0b698ca1d9fd927" "/opt/rustwide/cargo-home/bin/cargo" "+0d56e340472882fa673d4b98d0802b9a799879d0" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] 0007e2f67542442a1d5d48ef6ae1282d551a675cb72fb63b5f3497a62a6caafb
[INFO] running `Command { std: "docker" "start" "-a" "0007e2f67542442a1d5d48ef6ae1282d551a675cb72fb63b5f3497a62a6caafb", kill_on_drop: false }`
[INFO] [stderr]    Compiling proc-macro2 v1.0.37
[INFO] [stderr]    Compiling unicode-xid v0.2.3
[INFO] [stderr]    Compiling syn v1.0.92
[INFO] [stderr]    Compiling autocfg v1.1.0
[INFO] [stderr]    Compiling libc v0.2.125
[INFO] [stderr]    Compiling serde_derive v1.0.137
[INFO] [stderr]    Compiling serde v1.0.137
[INFO] [stderr]    Compiling memchr v2.5.0
[INFO] [stderr]     Checking cfg-if v1.0.0
[INFO] [stderr]    Compiling version_check v0.9.4
[INFO] [stderr]    Compiling serde_json v1.0.80
[INFO] [stderr]    Compiling cc v1.0.73
[INFO] [stderr]    Compiling log v0.4.17
[INFO] [stderr]    Compiling semver v1.0.9
[INFO] [stderr]    Compiling anyhow v1.0.57
[INFO] [stderr]    Compiling regex-syntax v0.6.25
[INFO] [stderr]    Compiling hashbrown v0.11.2
[INFO] [stderr]    Compiling itoa v1.0.1
[INFO] [stderr]    Compiling ryu v1.0.9
[INFO] [stderr]    Compiling tinyvec_macros v0.1.0
[INFO] [stderr]    Compiling futures-core v0.3.21
[INFO] [stderr]    Compiling matches v0.1.9
[INFO] [stderr]     Checking pin-project-lite v0.2.9
[INFO] [stderr]    Compiling unicode-bidi v0.3.8
[INFO] [stderr]    Compiling percent-encoding v2.1.0
[INFO] [stderr]     Checking scopeguard v1.1.0
[INFO] [stderr]     Checking lazy_static v1.4.0
[INFO] [stderr]    Compiling futures-channel v0.3.21
[INFO] [stderr]     Checking futures-sink v0.3.21
[INFO] [stderr]    Compiling futures-task v0.3.21
[INFO] [stderr]    Compiling unicode-width v0.1.9
[INFO] [stderr]    Compiling tree-sitter-loader v0.20.0
[INFO] [stderr]    Compiling ansi_term v0.12.1
[INFO] [stderr]    Compiling bitflags v1.3.2
[INFO] [stderr]    Compiling strsim v0.8.0
[INFO] [stderr]    Compiling chunked_transfer v1.4.0
[INFO] [stderr]    Compiling either v1.6.1
[INFO] [stderr]    Compiling utf8-width v0.1.6
[INFO] [stderr]    Compiling once_cell v1.10.0
[INFO] [stderr]    Compiling ascii v1.0.0
[INFO] [stderr]    Compiling same-file v1.0.6
[INFO] [stderr]    Compiling vec_map v0.8.2
[INFO] [stderr]    Compiling futures-util v0.3.21
[INFO] [stderr]    Compiling glob v0.3.0
[INFO] [stderr]    Compiling crossbeam-utils v0.8.8
[INFO] [stderr]     Checking pin-utils v0.1.0
[INFO] [stderr]     Checking futures-io v0.3.21
[INFO] [stderr]     Checking slab v0.4.6
[INFO] [stderr]    Compiling parking_lot_core v0.9.3
[INFO] [stderr]    Compiling rustc-hash v1.1.0
[INFO] [stderr]    Compiling smallbitvec v2.5.1
[INFO] [stderr]    Compiling difference v2.0.0
[INFO] [stderr]    Compiling webbrowser v0.5.5
[INFO] [stderr]    Compiling remove_dir_all v0.5.3
[INFO] [stderr]     Checking smallvec v1.8.0
[INFO] [stderr]     Checking bytes v1.1.0
[INFO] [stderr]    Compiling ref-cast v1.0.7
[INFO] [stderr]    Compiling unicode-segmentation v1.9.0
[INFO] [stderr]     Checking byteorder v1.4.3
[INFO] [stderr]    Compiling rayon-core v1.9.2
[INFO] [stderr]     Checking tuple_list v0.1.3
[INFO] [stderr]     Checking static_assertions v1.1.0
[INFO] [stderr]     Checking pusherator v0.1.0 (/opt/rustwide/workdir/pusherator)
[INFO] [stderr]     Checking ppv-lite86 v0.2.16
[INFO] [stderr]     Checking plotters-backend v0.3.2
[INFO] [stderr]     Checking regex-automata v0.1.10
[INFO] [stderr]     Checking itoa v0.4.8
[INFO] [stderr]     Checking half v1.8.2
[INFO] [stderr]     Checking oorandom v11.1.3
[INFO] [stderr]    Compiling crc32fast v1.3.2
[INFO] [stderr]     Checking adler v1.0.2
[INFO] [stderr]     Checking minimal-lexical v0.2.1
[INFO] [stderr]    Compiling heck v0.4.0
[INFO] [stderr]     Checking os_str_bytes v6.0.0
[INFO] [stderr]     Checking strsim v0.10.0
[INFO] [stderr]     Checking textwrap v0.15.0
[INFO] [stderr]     Checking base64 v0.13.0
[INFO] [stderr]     Checking num_threads v0.1.5
[INFO] [stderr]     Checking termcolor v1.1.3
[INFO] [stderr]     Checking timely_bytes v0.12.0
[INFO] [stderr]     Checking timely_logging v0.12.0
[INFO] [stderr]     Checking abomonation v0.7.3
[INFO] [stderr]     Checking fnv v1.0.7
[INFO] [stderr]    Compiling seq-macro v0.2.2
[INFO] [stderr]    Compiling xshell-macros v0.1.17
[INFO] [stderr]     Checking linked-hash-map v0.5.6
[INFO] [stderr]     Checking similar v2.2.0
[INFO] [stderr]     Checking fastrand v1.8.0
[INFO] [stderr]    Compiling indexmap v1.8.1
[INFO] [stderr]    Compiling num-traits v0.2.15
[INFO] [stderr]    Compiling num-integer v0.1.45
[INFO] [stderr]    Compiling lock_api v0.4.7
[INFO] [stderr]    Compiling memoffset v0.6.5
[INFO] [stderr]    Compiling crossbeam-epoch v0.9.8
[INFO] [stderr]    Compiling rayon v1.5.2
[INFO] [stderr]    Compiling slotmap v1.0.6
[INFO] [stderr]    Compiling proc-macro-error-attr v1.0.4
[INFO] [stderr]    Compiling proc-macro-error v1.0.4
[INFO] [stderr]    Compiling tinyvec v1.6.0
[INFO] [stderr]    Compiling libloading v0.7.3
[INFO] [stderr]    Compiling form_urlencoded v1.0.1
[INFO] [stderr]    Compiling textwrap v0.11.0
[INFO] [stderr]    Compiling tree-sitter v0.20.8
[INFO] [stderr]    Compiling html-escape v0.2.11
[INFO] [stderr]    Compiling walkdir v2.3.2
[INFO] [stderr]     Checking getopts v0.2.21
[INFO] [stderr]    Compiling heck v0.3.3
[INFO] [stderr]     Checking plotters-svg v0.3.1
[INFO] [stderr]     Checking itertools v0.10.3
[INFO] [stderr]     Checking miniz_oxide v0.5.1
[INFO] [stderr]     Checking clap_lex v0.2.0
[INFO] [stderr]     Checking yaml-rust v0.4.5
[INFO] [stderr]     Checking xshell v0.1.17
[INFO] [stderr]    Compiling unicode-normalization v0.1.21
[INFO] [stderr]     Checking aho-corasick v0.7.18
[INFO] [stderr]     Checking csv-core v0.1.10
[INFO] [stderr]     Checking nom v7.1.1
[INFO] [stderr]     Checking quote v1.0.18
[INFO] [stderr]     Checking num_cpus v1.13.1
[INFO] [stderr]     Checking mio v0.8.2
[INFO] [stderr]     Checking signal-hook-registry v1.4.0
[INFO] [stderr]     Checking socket2 v0.4.4
[INFO] [stderr]     Checking atty v0.2.14
[INFO] [stderr]     Checking getrandom v0.2.6
[INFO] [stderr]     Checking time v0.1.43
[INFO] [stderr]     Checking time v0.3.9
[INFO] [stderr]     Checking terminal_size v0.1.17
[INFO] [stderr]     Checking tempfile v3.3.0
[INFO] [stderr]    Compiling rustc_version v0.4.0
[INFO] [stderr]    Compiling dirs-sys v0.3.7
[INFO] [stderr]    Compiling which v4.2.5
[INFO] [stderr]    Compiling rand v0.4.6
[INFO] [stderr]     Checking crossbeam-channel v0.5.4
[INFO] [stderr]     Checking flate2 v1.0.23
[INFO] [stderr]     Checking regex v1.5.5
[INFO] [stderr]    Compiling idna v0.2.3
[INFO] [stderr]     Checking core_affinity v0.5.10
[INFO] [stderr]     Checking parking_lot v0.12.0
[INFO] [stderr]     Checking clap v2.34.0
[INFO] [stderr]     Checking colored v2.0.0
[INFO] [stderr]     Checking rand_core v0.6.3
[INFO] [stderr]     Checking plotters v0.3.1
[INFO] [stderr]     Checking console v0.15.1
[INFO] [stderr]    Compiling dirs v3.0.2
[INFO] [stderr]    Compiling cast v0.2.7
[INFO] [stderr]    Compiling tempdir v0.3.7
[INFO] [stderr]     Checking hdrhistogram v7.5.0
[INFO] [stderr]     Checking crossbeam-deque v0.8.1
[INFO] [stderr]    Compiling url v2.2.2
[INFO] [stderr]     Checking rand_chacha v0.3.1
[INFO] [stderr]     Checking insta v1.19.0
[INFO] [stderr]     Checking rand v0.8.5
[INFO] [stderr]     Checking criterion-plot v0.4.4
[INFO] [stderr]     Checking zipf v7.0.0
[INFO] [stderr]    Compiling rust-sitter-common v0.1.2 (https://github.com/hydro-project/rust-sitter#91d0526e)
[INFO] [stderr]    Compiling syn-inline-mod v0.5.0
[INFO] [stderr]    Compiling synstructure v0.12.6
[INFO] [stderr]    Compiling thiserror-impl v1.0.31
[INFO] [stderr]    Compiling futures-macro v0.3.21
[INFO] [stderr]    Compiling rust-sitter-macro v0.1.2 (https://github.com/hydro-project/rust-sitter#91d0526e)
[INFO] [stderr]    Compiling tokio-macros v1.7.0
[INFO] [stderr]    Compiling ref-cast-impl v1.0.7
[INFO] [stderr]    Compiling sealed v0.4.0
[INFO] [stderr]    Compiling clap_derive v3.1.7
[INFO] [stderr]    Compiling abomonation_derive v0.5.0
[INFO] [stderr]    Compiling rust-sitter v0.1.2 (https://github.com/hydro-project/rust-sitter#91d0526e)
[INFO] [stderr]     Checking tokio v1.18.1
[INFO] [stderr]    Compiling thiserror v1.0.31
[INFO] [stderr]    Compiling tree-sitter-tags v0.20.2
[INFO] [stderr]    Compiling tree-sitter-highlight v0.20.1
[INFO] [stderr]     Checking clap v3.1.15
[INFO] [stderr]     Checking futures-executor v0.3.21
[INFO] [stderr]     Checking futures v0.3.21
[INFO] [stderr]     Checking datadriven v0.6.0
[INFO] [stderr]     Checking tokio-util v0.6.9
[INFO] [stderr]     Checking tokio-stream v0.1.8
[INFO] [stderr]     Checking bincode v1.3.3
[INFO] [stderr]     Checking bstr v0.2.17
[INFO] [stderr]     Checking serde_cbor v0.11.2
[INFO] [stderr]     Checking chrono v0.4.19
[INFO] [stderr]     Checking timely_communication v0.12.0
[INFO] [stderr]     Checking toml v0.5.9
[INFO] [stderr]     Checking timely v0.12.0
[INFO] [stderr]     Checking csv v1.1.6
[INFO] [stderr]     Checking hydroflow_lang v0.1.0 (/opt/rustwide/workdir/hydroflow_lang)
[INFO] [stderr]     Checking tinytemplate v1.2.1
[INFO] [stderr]     Checking proc-macro-crate v1.1.3
[INFO] [stderr]     Checking criterion v0.3.5
[INFO] [stderr]     Checking hydroflow_macro v0.1.0 (/opt/rustwide/workdir/hydroflow_macro)
[INFO] [stderr]    Compiling tree-sitter-config v0.19.0
[INFO] [stderr]    Compiling tiny_http v0.8.2
[INFO] [stderr]     Checking differential-dataflow v0.12.0
[INFO] [stderr]    Compiling tree-sitter-cli v0.20.6
[INFO] [stderr]    Compiling rust-sitter-tool v0.1.2 (https://github.com/hydro-project/rust-sitter#91d0526e)
[INFO] [stderr]    Compiling hydroflow_datalog v0.1.0 (/opt/rustwide/workdir/hydroflow_datalog)
[INFO] [stderr]     Checking hydroflow v0.1.0 (/opt/rustwide/workdir/hydroflow)
[INFO] [stderr]     Checking relalg v0.1.0 (/opt/rustwide/workdir/relalg)
[INFO] [stderr]     Checking benches v0.1.0 (/opt/rustwide/workdir/benches)
[INFO] [stdout] warning: `merge` should have at least 2 input(s), actually has 1.
[INFO] [stdout]    --> hydroflow/tests/surface_codegen.rs:465:33
[INFO] [stdout]     |
[INFO] [stdout] 465 |         recv_iter([1, 2, 3]) -> merge() -> for_each(|x| output_inner.borrow_mut().push(x));
[INFO] [stdout]     |                                 ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: `tee` should have at least 2 output(s), actually has 1.
[INFO] [stdout]    --> hydroflow/tests/surface_codegen.rs:479:33
[INFO] [stdout]     |
[INFO] [stdout] 479 |         recv_iter([1, 2, 3]) -> tee() -> for_each(|x| output_inner.borrow_mut().push(x));
[INFO] [stdout]     |                                 ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] 1v1 = merge();
[INFO] [stdout] 2v1 = tee();
[INFO] [stdout] 3v1 = merge();
[INFO] [stdout] 4v1 = tee();
[INFO] [stdout] 5v1 = recv_stream(input);
[INFO] [stdout] 6v1 = for_each(| v | out.send(v).unwrap());
[INFO] [stdout] 7v1 = map(| row : (_, _,) | (row.1, row.0,));
[INFO] [stdout] 
[INFO] [stdout] (1v1-->2v1);
[INFO] [stdout] (2v1-->7v1);
[INFO] [stdout] (3v1-->4v1);
[INFO] [stdout] (4v1-->6v1);
[INFO] [stdout] (5v1-->1v1);
[INFO] [stdout] (7v1-->3v1);
[INFO] [stdout] 
[INFO] [stdout] 1v1 = merge();
[INFO] [stdout] 2v1 = tee();
[INFO] [stdout] 3v1 = merge();
[INFO] [stdout] 4v1 = tee();
[INFO] [stdout] 5v1 = recv_stream(input);
[INFO] [stdout] 6v1 = for_each(| v | out.send(v).unwrap());
[INFO] [stdout] 7v1 = join();
[INFO] [stdout] 8v1 = map(| kv : ((_, _,), ((_, _,), (_, _,))) | (kv.1.0.0, kv.1.0.1,));
[INFO] [stdout] 9v1 = map(| v : (_, _,) | ((v.0, v.1,), v));
[INFO] [stdout] 10v1 = map(| v : (_, _,) | ((v.1, v.0,), v));
[INFO] [stdout] 11v1 = map(| row : (_, _,) | (row.0, row.1,));
[INFO] [stdout] 
[INFO] [stdout] (1v1-->2v1);
[INFO] [stdout] (2v1-->9v1);
[INFO] [stdout] (2v1-->10v1);
[INFO] [stdout] (3v1-->4v1);
[INFO] [stdout] (4v1-->6v1);
[INFO] [stdout] (5v1-->1v1);
[INFO] [stdout] (7v1-->8v1);
[INFO] [stdout] (8v1-->11v1);
[INFO] [stdout] (9v1-->7v1);
[INFO] [stdout] (10v1-->7v1);
[INFO] [stdout] (11v1-->3v1);
[INFO] [stdout] 
[INFO] [stdout] warning: 2 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] 1v1 = merge();
[INFO] [stdout] 2v1 = tee();
[INFO] [stdout] 3v1 = merge();
[INFO] [stdout] 4v1 = tee();
[INFO] [stdout] 5v1 = merge();
[INFO] [stdout] 6v1 = tee();
[INFO] [stdout] 7v1 = recv_stream(input);
[INFO] [stdout] 8v1 = for_each(| v | out.send(v).unwrap());
[INFO] [stdout] 9v1 = map(| row : (_, _,) | (row.0, row.1,));
[INFO] [stdout] 10v1 = join();
[INFO] [stdout] 11v1 = map(| kv : ((_, _,), ((_, _,), (_, _,))) | (kv.1.0.0, kv.1.0.1,));
[INFO] [stdout] 12v1 = map(| v : (_, _,) | ((v.0, v.1,), v));
[INFO] [stdout] 13v1 = map(| v : (_, _,) | ((v.1, v.0,), v));
[INFO] [stdout] 14v1 = map(| row : (_, _,) | (row.0, row.1,));
[INFO] [stdout] 
[INFO] [stdout] (1v1-->2v1);
[INFO] [stdout] (2v1-->9v1);
[INFO] [stdout] (3v1-->4v1);
[INFO] [stdout] (4v1-->8v1);
[INFO] [stdout] (5v1-->6v1);
[INFO] [stdout] (6v1-->12v1);
[INFO] [stdout] (6v1-->13v1);
[INFO] [stdout] (7v1-->1v1);
[INFO] [stdout] (9v1-->5v1);
[INFO] [stdout] (10v1-->11v1);
[INFO] [stdout] (11v1-->14v1);
[INFO] [stdout] (12v1-->10v1);
[INFO] [stdout] (13v1-->10v1);
[INFO] [stdout] (14v1-->3v1);
[INFO] [stdout] 
[INFO] [stdout] 1v1 = merge();
[INFO] [stdout] 2v1 = tee();
[INFO] [stdout] 3v1 = merge();
[INFO] [stdout] 4v1 = tee();
[INFO] [stdout] 5v1 = merge();
[INFO] [stdout] 6v1 = tee();
[INFO] [stdout] 7v1 = recv_stream(in1);
[INFO] [stdout] 8v1 = recv_stream(in2);
[INFO] [stdout] 9v1 = for_each(| v | out.send(v).unwrap());
[INFO] [stdout] 10v1 = join();
[INFO] [stdout] 11v1 = map(| kv : ((_, _,), ((_, _,), (_, _,))) | (kv.1.0.0, kv.1.0.1,));
[INFO] [stdout] 12v1 = map(| v : (_, _,) | ((v.0, v.1,), v));
[INFO] [stdout] 13v1 = map(| v : (_, _,) | ((v.1, v.0,), v));
[INFO] [stdout] 14v1 = map(| row : (_, _,) | (row.0, row.1,));
[INFO] [stdout] 
[INFO] [stdout] (1v1-->2v1);
[INFO] [stdout] (2v1-->12v1);
[INFO] [stdout] (3v1-->4v1);
[INFO] [stdout] (4v1-->13v1);
[INFO] [stdout] (5v1-->6v1);
[INFO] [stdout] (6v1-->9v1);
[INFO] [stdout] (7v1-->1v1);
[INFO] [stdout] (8v1-->3v1);
[INFO] [stdout] (10v1-->11v1);
[INFO] [stdout] (11v1-->14v1);
[INFO] [stdout] (12v1-->10v1);
[INFO] [stdout] (13v1-->10v1);
[INFO] [stdout] (14v1-->5v1);
[INFO] [stdout] 
[INFO] [stdout] 1v1 = merge();
[INFO] [stdout] 2v1 = tee();
[INFO] [stdout] 3v1 = merge();
[INFO] [stdout] 4v1 = tee();
[INFO] [stdout] 5v1 = merge();
[INFO] [stdout] 6v1 = tee();
[INFO] [stdout] 7v1 = recv_stream(in1);
[INFO] [stdout] 8v1 = recv_stream(in2);
[INFO] [stdout] 9v1 = for_each(| v | out.send(v).unwrap());
[INFO] [stdout] 10v1 = map(| row : (_, _,) | (row.0, row.1,));
[INFO] [stdout] 11v1 = map(| row : (_, _,) | (row.1, row.0,));
[INFO] [stdout] 
[INFO] [stdout] (1v1-->2v1);
[INFO] [stdout] (2v1-->10v1);
[INFO] [stdout] (3v1-->4v1);
[INFO] [stdout] (4v1-->11v1);
[INFO] [stdout] (5v1-->6v1);
[INFO] [stdout] (6v1-->9v1);
[INFO] [stdout] (7v1-->1v1);
[INFO] [stdout] (8v1-->3v1);
[INFO] [stdout] (10v1-->5v1);
[INFO] [stdout] (11v1-->5v1);
[INFO] [stdout] 
[INFO] [stdout] 1v1 = merge();
[INFO] [stdout] 2v1 = tee();
[INFO] [stdout] 3v1 = merge();
[INFO] [stdout] 4v1 = tee();
[INFO] [stdout] 5v1 = merge();
[INFO] [stdout] 6v1 = tee();
[INFO] [stdout] 7v1 = recv_stream(edges);
[INFO] [stdout] 8v1 = recv_stream(seed_reachable);
[INFO] [stdout] 9v1 = for_each(| v | reachable.send(v).unwrap());
[INFO] [stdout] 10v1 = map(| row : (_,) | (row.0,));
[INFO] [stdout] 11v1 = join();
[INFO] [stdout] 12v1 = map(| kv : ((_,), ((_,), (_, _,))) | (kv.1.0.0, kv.1.1.1,));
[INFO] [stdout] 13v1 = map(| v : (_,) | ((v.0,), v));
[INFO] [stdout] 14v1 = map(| v : (_, _,) | ((v.0,), v));
[INFO] [stdout] 15v1 = map(| row : (_, _,) | (row.1,));
[INFO] [stdout] 
[INFO] [stdout] (1v1-->2v1);
[INFO] [stdout] (2v1-->14v1);
[INFO] [stdout] (3v1-->4v1);
[INFO] [stdout] (4v1-->10v1);
[INFO] [stdout] (5v1-->6v1);
[INFO] [stdout] (6v1-->9v1);
[INFO] [stdout] (6v1-->13v1);
[INFO] [stdout] (7v1-->1v1);
[INFO] [stdout] (8v1-->3v1);
[INFO] [stdout] (10v1-->5v1);
[INFO] [stdout] (11v1-->12v1);
[INFO] [stdout] (12v1-->15v1);
[INFO] [stdout] (13v1-->11v1);
[INFO] [stdout] (14v1-->11v1);
[INFO] [stdout] (15v1-->5v1);
[INFO] [stdout] 
[INFO] [stdout] 1v1 = merge();
[INFO] [stdout] 2v1 = tee();
[INFO] [stdout] 3v1 = merge();
[INFO] [stdout] 4v1 = tee();
[INFO] [stdout] 5v1 = merge();
[INFO] [stdout] 6v1 = tee();
[INFO] [stdout] 7v1 = merge();
[INFO] [stdout] 8v1 = tee();
[INFO] [stdout] 9v1 = recv_stream(in1);
[INFO] [stdout] 10v1 = recv_stream(in2);
[INFO] [stdout] 11v1 = recv_stream(in3);
[INFO] [stdout] 12v1 = for_each(| v | out.send(v).unwrap());
[INFO] [stdout] 13v1 = join();
[INFO] [stdout] 14v1 = map(| kv : ((_,), ((_, _,), (_, _,))) | (kv.1.0.0, kv.1.0.1, kv.1.1.1,));
[INFO] [stdout] 15v1 = map(| v : (_, _,) | ((v.1,), v));
[INFO] [stdout] 16v1 = map(| v : (_, _,) | ((v.0,), v));
[INFO] [stdout] 17v1 = join();
[INFO] [stdout] 18v1 = map(| kv : ((_,), ((_, _, _,), (_, _,))) |
[INFO] [stdout] (kv.1.0.0, kv.1.0.1, kv.1.0.2, kv.1.1.1,));
[INFO] [stdout] 19v1 = map(| v : (_, _, _,) | ((v.2,), v));
[INFO] [stdout] 20v1 = map(| v : (_, _,) | ((v.0,), v));
[INFO] [stdout] 21v1 = map(| row : (_, _, _, _,) | (row.3, row.2, row.1, row.0,));
[INFO] [stdout] 
[INFO] [stdout] (1v1-->2v1);
[INFO] [stdout] (2v1-->15v1);
[INFO] [stdout] (3v1-->4v1);
[INFO] [stdout] (4v1-->16v1);
[INFO] [stdout] (5v1-->6v1);
[INFO] [stdout] (6v1-->20v1);
[INFO] [stdout] (7v1-->8v1);
[INFO] [stdout] (8v1-->12v1);
[INFO] [stdout] (9v1-->1v1);
[INFO] [stdout] (10v1-->3v1);
[INFO] [stdout] (11v1-->5v1);
[INFO] [stdout] (13v1-->14v1);
[INFO] [stdout] (14v1-->19v1);
[INFO] [stdout] (15v1-->13v1);
[INFO] [stdout] (16v1-->13v1);
[INFO] [stdout] (17v1-->18v1);
[INFO] [stdout] (18v1-->21v1);
[INFO] [stdout] (19v1-->17v1);
[INFO] [stdout] (20v1-->17v1);
[INFO] [stdout] (21v1-->7v1);
[INFO] [stdout] 
[INFO] [stdout] 1v1 = merge();
[INFO] [stdout] 2v1 = tee();
[INFO] [stdout] 3v1 = merge();
[INFO] [stdout] 4v1 = tee();
[INFO] [stdout] 5v1 = recv_stream(input);
[INFO] [stdout] 6v1 = for_each(| v | out.send(v).unwrap());
[INFO] [stdout] 7v1 = filter(| & row : & (_, _,) | row.0 == row.1);
[INFO] [stdout] 8v1 = map(| row : (_, _,) | (row.0, row.0,));
[INFO] [stdout] 
[INFO] [stdout] (1v1-->2v1);
[INFO] [stdout] (2v1-->7v1);
[INFO] [stdout] (3v1-->4v1);
[INFO] [stdout] (4v1-->6v1);
[INFO] [stdout] (5v1-->1v1);
[INFO] [stdout] (7v1-->8v1);
[INFO] [stdout] (8v1-->3v1);
[INFO] [stdout] 
[INFO] [stderr]     Finished dev [unoptimized + debuginfo] target(s) in 58.37s
[INFO] running `Command { std: "docker" "inspect" "0007e2f67542442a1d5d48ef6ae1282d551a675cb72fb63b5f3497a62a6caafb", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "0007e2f67542442a1d5d48ef6ae1282d551a675cb72fb63b5f3497a62a6caafb", kill_on_drop: false }`
[INFO] [stdout] 0007e2f67542442a1d5d48ef6ae1282d551a675cb72fb63b5f3497a62a6caafb