feat: Adding hand-crafted precompute engine option in e2e quickstart

.dockerignore

@@ -0,0 +1,2 @@
+target/
+.git/

.gitignore

@@ -1,5 +1,6 @@
 target/
 experiment_outputs/
+asap-quickstart/bin/
 
 # Runtime and generated files
 metadata/

asap-common/dependencies/rs/asap_types/src/streaming_config.rs

@@ -1,5 +1,4 @@
 use anyhow::Result;
-use core::panic;
 use serde::{Deserialize, Serialize};
 use serde_yaml::Value;
 use std::collections::HashMap;
@@ -83,7 +82,12 @@ impl StreamingConfig {
         if let Some(aggregations) = data.get("aggregations").and_then(|v| v.as_sequence()) {
             for aggregation_data in aggregations {
                 if let Some(aggregation_id) = aggregation_data.get("aggregationId") {
-                    let aggregation_id_u64 = aggregation_id.as_u64().or_else(|| panic!()).unwrap();
+                    let aggregation_id_u64 = aggregation_id.as_u64().ok_or_else(|| {
+                        anyhow::anyhow!(
+                            "aggregationId must be a valid u64, got: {:?}",
+                            aggregation_id
+                        )
+                    })?;
                     let num_aggregates_to_retain = retention_map.get(&aggregation_id_u64);
                     let read_count_threshold = read_count_threshold_map.get(&aggregation_id_u64);
                     let config = AggregationConfig::from_yaml_data(

asap-query-engine/Cargo.toml

@@ -72,6 +72,10 @@ path = "src/bin/test_e2e_precompute.rs"
 name = "bench_precompute_sketch"
 path = "src/bin/bench_precompute_sketch.rs"
 
+[[bin]]
+name = "e2e_quickstart_resource_test"
+path = "src/bin/e2e_quickstart_resource_test.rs"
+
 [dev-dependencies]
 ctor = "0.2"
 tempfile = "3.20.0"

asap-query-engine/Dockerfile

@@ -31,6 +31,7 @@ RUN mkdir -p asap-query-engine/src/bin \
     && echo "fn main() {}" > asap-query-engine/src/bin/precompute_engine.rs \
     && echo "fn main() {}" > asap-query-engine/src/bin/test_e2e_precompute.rs \
     && echo "fn main() {}" > asap-query-engine/src/bin/bench_precompute_sketch.rs \
+    && echo "fn main() {}" > asap-query-engine/src/bin/e2e_quickstart_resource_test.rs \
     && mkdir -p asap-query-engine/benches && echo "fn main() {}" > asap-query-engine/benches/simple_store_bench.rs \
     && mkdir -p asap-planner-rs/src && echo "fn main() {}" > asap-planner-rs/src/main.rs \
     && echo "pub fn placeholder() {}" >> asap-planner-rs/src/lib.rs