Update parachain struct with newly introduced field

Author: rockbmb

core/src/common/empty_block/inherents/custom_idps/para_parachain.rs

@@ -20,6 +20,7 @@
 
 use std::{ops::DerefMut, sync::Arc};
 
+use cumulus_primitives_core::relay_chain::UpgradeGoAhead;
 use parity_scale_codec::{Decode, Encode};
 use polkadot_primitives::{BlockNumber, HeadData};
 use sp_consensus_babe::SlotDuration;
@@ -119,6 +120,7 @@ impl<B: BlockT> sp_inherents::InherentDataProvider for InherentDataProvider<B> {
             raw_horizontal_messages: Default::default(),
             additional_key_values: Some(additional_key_values),
             para_id: para_id.into(),
+            upgrade_go_ahead: Some(UpgradeGoAhead::GoAhead),
         }
         .provide_inherent_data(inherent_data)
         .await

core/tests/create_snapshot.rs

@@ -42,7 +42,11 @@ async fn create_snapshot_works() {
         match common::start_node_inline(vec![
             "--no-hardware-benchmarks",
             "--dev",
+            "--tmp",
             format!("--rpc-port={}", port).as_str(),
+            "--no-telemetry",
+            "--no-prometheus",
+            "--rpc-max-response-size=1000", // Allow large RPC responses for snapshot creation
         ]) {
             Ok(_) => {}
             Err(e) => {
@@ -51,7 +55,7 @@ async fn create_snapshot_works() {
         }
     });
     // Wait some time to ensure the node is warmed up.
-    std::thread::sleep(Duration::from_secs(90));
+    std::thread::sleep(Duration::from_secs(180));
 
     // Run the command with tokio
     let temp_dir = tempfile::Builder::new()
@@ -84,6 +88,12 @@ async fn create_snapshot_works() {
         let child = create_snapshot(&ws_url, &snap_file_path, block_hash);
         let out = child.wait_with_output().await.unwrap();
 
+        if !out.status.success() {
+            eprintln!("\n❌ create-snapshot failed!");
+            eprintln!("Status: {:?}", out.status);
+            eprintln!("\nStdout:\n{}", String::from_utf8_lossy(&out.stdout));
+            eprintln!("\nStderr:\n{}", String::from_utf8_lossy(&out.stderr));
+        }
         assert!(out.status.success());
 
         let snapshot_is_on_disk = Path::new(&snap_file_path).exists();

core/tests/execute_block.rs

@@ -33,7 +33,11 @@ async fn execute_block_works() {
         match common::start_node_inline(vec![
             "--no-hardware-benchmarks",
             "--dev",
+            "--tmp",
             format!("--rpc-port={}", port).as_str(),
+            "--no-telemetry",
+            "--no-prometheus",
+            "--rpc-max-response-size=1000", // Allow large RPC responses
         ]) {
             Ok(_) => {}
             Err(e) => {
@@ -42,7 +46,7 @@ async fn execute_block_works() {
         }
     });
     // Wait some time to ensure the node is warmed up.
-    std::thread::sleep(Duration::from_secs(90));
+    std::thread::sleep(Duration::from_secs(180));
 
     // Test passing --at
     common::run_with_timeout(Duration::from_secs(60), async move {
@@ -74,6 +78,9 @@ async fn execute_block_works() {
             common::wait_for_stream_pattern_match(block_execution.stderr.take().unwrap(), re).await;
 
         // Assert that the block-execution process has executed the expected block.
+        if let Err(ref e) = matched {
+            println!("Error: {}", e);
+        }
         assert!(matched.is_ok());
 
         // Assert that the block-execution exited succesfully