hawdb-executor 0.16.0

load("@crate_index//:defs.bzl", "aliases", "all_crate_deps")
load("@rules_rust//rust:defs.bzl", "rust_library", "rust_test")

package(default_visibility = ["//visibility:public"])

filegroup(
    name = "query_limit_inventory_sources",
    srcs = glob(["src/**/*.rs"]),
    visibility = ["//:__pkg__"],
)

test_suite(
    name = "presubmit_tests",
)

rust_library(
    name = "hawdb_executor",
    crate_name = "hawdb_executor",
    crate_root = "src/lib.rs",
    srcs = glob(["src/**/*.rs"]),
    edition = "2024",
    aliases = aliases(),
    deps = all_crate_deps(normal = True) + [
        "//crates/analytics:hawdb_analytics",
        "//crates/core:hawdb_core",
        "//crates/ddl:hawdb_ddl",
        "//crates/plan-cypher:hawdb_plan_cypher",
        "//crates/qos:hawdb_qos",
        "//crates/storage:hawdb_storage",
    ],
    proc_macro_deps = all_crate_deps(proc_macro = True),
)

rust_test(
    name = "hawdb_executor_unit_tests",
    crate = ":hawdb_executor",
    edition = "2024",
    aliases = aliases(normal_dev = True, proc_macro_dev = True),
    deps = all_crate_deps(normal_dev = True),
    proc_macro_deps = all_crate_deps(proc_macro_dev = True),
)

rust_test(
    name = "hawdb_batch_dispatch_fuzz_tests",
    size = "small",
    args = [
        "batch::tests::dispatch::batch_dispatch_campaign",
        "--exact",
        "--ignored",
        "--nocapture",
    ],
    crate = ":hawdb_executor",
    edition = "2024",
    tags = ["manual"],
    aliases = aliases(normal_dev = True, proc_macro_dev = True),
    deps = all_crate_deps(normal_dev = True),
    proc_macro_deps = all_crate_deps(proc_macro_dev = True),
)

[
    rust_test(
        name = name,
        srcs = ["tests/morsel_oracle.rs"],
        crate_root = "tests/morsel_oracle.rs",
        size = "small",
        args = args,
        tags = tags,
        edition = "2024",
        aliases = aliases(normal_dev = True, proc_macro_dev = True),
        deps = all_crate_deps(normal_dev = True) + [
            ":hawdb_executor",
            "//crates/core:hawdb_core",
        ],
        proc_macro_deps = all_crate_deps(proc_macro_dev = True),
    )
    for name, args, tags in [
        ("hawdb_morsel_oracle_tests", [], []),
        ("hawdb_morsel_oracle_fuzz_tests", ["scheduler_differential_campaign", "--exact", "--ignored", "--nocapture"], ["manual"]),
    ]
]

# The existing CI entrypoint must consume public contracts as well as unit tests.
test_suite(
    name = "hawdb_executor_tests",
    tests = [
        ":hawdb_executor_unit_tests",
        ":hawdb_morsel_oracle_tests",
        ":hawdb_projection_allocation_tests",
        ":hawdb_query_observer_release_tests",
    ],
)

rust_test(
    name = "hawdb_projection_allocation_tests",
    srcs = ["tests/projection_allocation.rs"],
    crate_root = "tests/projection_allocation.rs",
    size = "small",
    edition = "2024",
    aliases = aliases(normal_dev = True, proc_macro_dev = True),
    deps = all_crate_deps(normal_dev = True) + [
        ":hawdb_executor",
        "//crates/core:hawdb_core",
        "//crates/plan-cypher:hawdb_plan_cypher",
        "//crates/storage:hawdb_storage",
    ],
    proc_macro_deps = all_crate_deps(proc_macro_dev = True),
)

rust_test(
    name = "hawdb_execution_report_value_fuzz_tests",
    size = "small",
    args = [
        "observer::report_value::tests::execution_report_value_differential_campaign",
        "--exact",
        "--ignored",
        "--nocapture",
    ],
    crate = ":hawdb_executor",
    edition = "2024",
    tags = ["manual"],
    aliases = aliases(normal_dev = True, proc_macro_dev = True),
    deps = all_crate_deps(normal_dev = True),
    proc_macro_deps = all_crate_deps(proc_macro_dev = True),
)

rust_test(
    name = "hawdb_execution_lifecycle_fuzz_tests",
    size = "small",
    args = [
        "observer::profile::tests::execution_lifecycle_differential_campaign",
        "--exact",
        "--ignored",
        "--nocapture",
    ],
    crate = ":hawdb_executor",
    edition = "2024",
    tags = ["manual"],
    aliases = aliases(normal_dev = True, proc_macro_dev = True),
    deps = all_crate_deps(normal_dev = True),
    proc_macro_deps = all_crate_deps(proc_macro_dev = True),
)

rust_test(
    name = "hawdb_result_delivery_fuzz_tests",
    size = "small",
    args = [
        "result_delivery::tests::differential::result_delivery_differential_campaign",
        "--exact",
        "--ignored",
        "--nocapture",
    ],
    crate = ":hawdb_executor",
    edition = "2024",
    tags = ["manual"],
    aliases = aliases(normal_dev = True, proc_macro_dev = True),
    deps = all_crate_deps(normal_dev = True),
    proc_macro_deps = all_crate_deps(proc_macro_dev = True),
)

rust_test(
    name = "hawdb_numeric_execution_fuzz_tests",
    size = "small",
    args = [
        "numeric::differential::numeric_execution_differential_campaign",
        "--exact",
        "--ignored",
        "--nocapture",
    ],
    crate = ":hawdb_executor",
    edition = "2024",
    tags = ["manual"],
    aliases = aliases(normal_dev = True, proc_macro_dev = True),
    deps = all_crate_deps(normal_dev = True),
    proc_macro_deps = all_crate_deps(proc_macro_dev = True),
)

rust_test(
    name = "hawdb_query_observer_release_tests",
    args = [
        "observer::query::tests::query_observer_registration_without_debug_assertions",
        "--exact",
        "--ignored",
    ],
    crate = ":hawdb_executor",
    edition = "2024",
    # Explicitly selected under the repository-wide --config=release profile.
    tags = ["manual"],
    aliases = aliases(normal_dev = True, proc_macro_dev = True),
    deps = all_crate_deps(normal_dev = True),
    proc_macro_deps = all_crate_deps(proc_macro_dev = True),
)

rust_test(
    name = "hawdb_query_observer_fuzz_tests",
    size = "small",
    args = [
        "observer::query::tests::query_observer_event_differential_campaign",
        "--exact",
        "--ignored",
        "--nocapture",
    ],
    crate = ":hawdb_executor",
    edition = "2024",
    tags = ["manual"],
    aliases = aliases(normal_dev = True, proc_macro_dev = True),
    deps = all_crate_deps(normal_dev = True),
    proc_macro_deps = all_crate_deps(proc_macro_dev = True),
)

rust_test(
    name = "hawdb_mutation_lowering_fuzz_tests",
    size = "small",
    args = [
        "mutation::tests::mutation_lowering_differential_campaign",
        "--exact",
        "--ignored",
        "--nocapture",
    ],
    crate = ":hawdb_executor",
    edition = "2024",
    tags = ["manual"],
    aliases = aliases(normal_dev = True, proc_macro_dev = True),
    deps = all_crate_deps(normal_dev = True),
    proc_macro_deps = all_crate_deps(proc_macro_dev = True),
)

rust_test(
    name = "hawdb_mutation_preflight_fuzz_tests",
    size = "small",
    args = [
        "mutation::preflight::tests::mutation_preflight_differential_campaign",
        "--exact",
        "--ignored",
        "--nocapture",
    ],
    crate = ":hawdb_executor",
    edition = "2024",
    tags = ["manual"],
    aliases = aliases(normal_dev = True, proc_macro_dev = True),
    deps = all_crate_deps(normal_dev = True),
    proc_macro_deps = all_crate_deps(proc_macro_dev = True),
)

rust_test(
    name = "hawdb_sort_merge_account_fuzz_tests",
    size = "small",
    # The containing local campaign exceeded the inherited 60-second deadline.
    timeout = "moderate",
    args = [
        "blocking::sort::tests::sort_merge_account_differential_campaign",
        "--exact",
        "--ignored",
        "--nocapture",
    ],
    crate = ":hawdb_executor",
    edition = "2024",
    tags = ["manual"],
    aliases = aliases(normal_dev = True, proc_macro_dev = True),
    deps = all_crate_deps(normal_dev = True),
    proc_macro_deps = all_crate_deps(proc_macro_dev = True),
)

rust_test(
    name = "hawdb_transform_fuzz_tests",
    size = "small",
    args = [
        "transform::tests::transform_differential_campaign",
        "--exact",
        "--ignored",
        "--nocapture",
    ],
    crate = ":hawdb_executor",
    edition = "2024",
    tags = ["manual"],
    aliases = aliases(normal_dev = True, proc_macro_dev = True),
    deps = all_crate_deps(normal_dev = True),
    proc_macro_deps = all_crate_deps(proc_macro_dev = True),
)

rust_test(
    name = "hawdb_graph_algorithm_fuzz_tests",
    size = "small",
    args = [
        "analytics::tests::differential::graph_algorithm_differential_campaign",
        "--exact",
        "--ignored",
        "--nocapture",
    ],
    crate = ":hawdb_executor",
    edition = "2024",
    tags = ["manual"],
    aliases = aliases(normal_dev = True, proc_macro_dev = True),
    deps = all_crate_deps(normal_dev = True),
    proc_macro_deps = all_crate_deps(proc_macro_dev = True),
)

rust_test(
    name = "hawdb_vector_seed_fuzz_tests",
    size = "small",
    args = [
        "external::seed::tests::differential::vector_seed_differential_campaign",
        "--exact",
        "--ignored",
        "--nocapture",
    ],
    crate = ":hawdb_executor",
    edition = "2024",
    tags = ["manual"],
    aliases = aliases(normal_dev = True, proc_macro_dev = True),
    deps = all_crate_deps(normal_dev = True),
    proc_macro_deps = all_crate_deps(proc_macro_dev = True),
)

rust_test(
    name = "hawdb_spill_compaction_fuzz_tests",
    timeout = "long",
    args = [
        "spill::compaction::tests::compaction_differential_campaign",
        "--exact",
        "--ignored",
        "--nocapture",
    ],
    crate = ":hawdb_executor",
    edition = "2024",
    tags = ["manual"],
    aliases = aliases(normal_dev = True, proc_macro_dev = True),
    deps = all_crate_deps(normal_dev = True),
    proc_macro_deps = all_crate_deps(proc_macro_dev = True),
)

rust_test(
    name = "hawdb_graph_hash_join_fuzz_tests",
    timeout = "long",
    args = [
        "blocking::join::tests::graph_hash_join_differential_campaign",
        "--exact",
        "--ignored",
        "--nocapture",
    ],
    crate = ":hawdb_executor",
    edition = "2024",
    tags = ["manual"],
    aliases = aliases(normal_dev = True, proc_macro_dev = True),
    deps = all_crate_deps(normal_dev = True),
    proc_macro_deps = all_crate_deps(proc_macro_dev = True),
)