fix(workload): allow omitted cadence for non-PromQL payloads

Author: zzylol

crates/types/src/workload.rs

@@ -532,6 +532,7 @@ pub struct DataWorkload {
     pub arrival: DataArrival,
     /// Cadence at which each PromQL source supplies a sample. PromQL instant
     /// selectors use this as their explicit selection horizon.
+    #[serde(default)]
     pub data_ingestion_interval: Evidence<DurationMs>,
     pub ingestion_volume: Evidence<u64>,
     pub ingestion_rate: Evidence<Rate>,

crates/types/tests/workload_compatibility.rs

@@ -0,0 +1,31 @@
+use asap_types::workload::{DataWorkload, QueryLanguage, QueryWorkload, SqlDialect};
+
+// Non-PromQL wire workloads should not require a PromQL-only cadence fact.
+#[test]
+fn non_promql_payload_accepts_absent_ingestion_interval() {
+    for language in [
+        QueryLanguage::DataFusion,
+        QueryLanguage::SQL(SqlDialect::DataFusionSQL),
+    ] {
+        let workload = QueryWorkload {
+            language,
+            query_batch: None,
+            repeating_queries: None,
+            data_workload: Some(DataWorkload::default()),
+        };
+        workload.validate().unwrap();
+        let mut payload = serde_json::to_value(&workload).unwrap();
+        payload["data_workload"]
+            .as_object_mut()
+            .unwrap()
+            .remove("data_ingestion_interval");
+        let decoded = serde_json::from_value::<QueryWorkload>(payload.clone()).unwrap();
+        decoded.validate().unwrap();
+        payload["language"] = serde_json::json!("promql");
+        let promql = serde_json::from_value::<QueryWorkload>(payload).unwrap();
+        assert_eq!(
+            promql.validate(),
+            Err(asap_types::workload::WorkloadError::MissingDataIngestionInterval)
+        );
+    }
+}