Merge branch 'main' into validation-framework-transport-header

Author: c1ly

.github/workflows/rust-validation-tests.yml

@@ -15,6 +15,16 @@ permissions:
 
 on:
   workflow_dispatch:
+    inputs:
+      pr_number:
+        description: "Pull request number to run validation tests against"
+        required: true
+        type: number
+
+# Cancel in-progress runs for the same PR if a new manual run is started
+concurrency:
+  group: ${{ github.workflow }}-${{ inputs.pr_number }}
+  cancel-in-progress: true
 
 env:
   CARGO_TERM_COLOR: always
@@ -23,9 +33,12 @@ jobs:
   validation_tests:
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd # v6.0.2
+      - name: Checkout PR merge ref
+        uses: actions/checkout@de0fac2e4500dabe0009e67214ff5f5447ce83dd # v6.0.2
         with:
+          ref: refs/pull/${{ inputs.pr_number }}/merge
           submodules: true
+          fetch-depth: 0
       - uses: arduino/setup-protoc@c65c819552d16ad3c9b72d9dfd5ba5237b9c906b # v3.0.0
         with:
           repo-token: ${{ secrets.GITHUB_TOKEN }}

rust/otap-dataflow/crates/pdata/src/otap/transform/util.rs

@@ -72,7 +72,7 @@ macro_rules! id_column_dispatch {
 pub(crate) use id_column_dispatch;
 
 /// Create a new record batch by taking the specified ranges from the provided record batch.
-pub(crate) fn take_record_batch_ranges(
+pub fn take_record_batch_ranges(
     rb: &RecordBatch,
     ranges: &[Range<usize>],
 ) -> arrow::error::Result<RecordBatch> {

rust/otap-dataflow/crates/query-engine/src/consts.rs

@@ -2,6 +2,7 @@
 // SPDX-License-Identifier: Apache-2.0
 
 pub(crate) const ATTRIBUTES_FIELD_NAME: &str = "attributes";
+pub(crate) const BODY_FIELD_NAME: &str = "body";
 pub(crate) const RESOURCES_FIELD_NAME: &str = "resource";
 pub(crate) const SCOPE_FIELD_NAME: &str = "instrumentation_scope";
 pub(crate) const VALUE_FIELD_NAME: &str = "value";