chore: improve dal integration test performance

lib/dal/tests/integration_test/action.rs

@@ -134,7 +134,7 @@ async fn set_state(ctx: &mut DalContext) -> Result<()> {
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn run(ctx: &mut DalContext) -> Result<()> {
     let component =
         create_component_for_default_schema_name_in_default_view(ctx, "swifty", "shake it off")
@@ -190,7 +190,7 @@ async fn auto_queue_creation(ctx: &mut DalContext) -> Result<()> {
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn auto_queue_update(ctx: &mut DalContext) -> Result<()> {
     // ======================================================
     // Creating a component  should enqueue a create action
@@ -327,7 +327,7 @@ async fn auto_queue_update(ctx: &mut DalContext) -> Result<()> {
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn refresh_actions_run_where_they_should(ctx: &mut DalContext) -> Result<()> {
     // small even schema can be used to test this!
     // First, we'll create a new component and apply (and wait for the create action to run)
@@ -436,7 +436,7 @@ async fn refresh_actions_run_where_they_should(ctx: &mut DalContext) -> Result<(
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn resource_value_propagation_subscriptions_works(ctx: &mut DalContext) -> Result<()> {
     // create 2 variants A & B where A has a resource_value prop that B is subscribed to
     let component_a_code_definition = r#"

lib/dal/tests/integration_test/action/schema_level.rs

@@ -22,7 +22,7 @@ use dal_test::{
 };
 use pretty_assertions_sorted::assert_eq;
 
-#[test]
+#[test(enable_veritech)]
 async fn schema_level_action_prototype(ctx: &mut DalContext) -> Result<()> {
     let schema = Schema::get_by_name(ctx, "swifty").await?;
     let default_schema_variant_id = Schema::default_variant_id(ctx, schema.id()).await?;

lib/dal/tests/integration_test/asset.rs

@@ -15,7 +15,7 @@ use dal_test::{
     test,
 };
 
-#[test]
+#[test(enable_veritech)]
 async fn asset_func_execution_papercuts(ctx: &mut DalContext) {
     let (schema_name, unstable_schema_variant_id) = {
         let schema_variant = VariantAuthoringClient::create_schema_and_variant(

lib/dal/tests/integration_test/attribute_value.rs

@@ -45,7 +45,7 @@ async fn arguments_for_prototype_function_execution(ctx: &mut DalContext) -> Res
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn attribute_value_path(ctx: &mut DalContext) -> Result<()> {
     // Create a component and commit. For context, the test exclusive schema has the identity
     // function set on "/root/domain/name" with an input from "/root/si/name". We need to ensure
@@ -128,7 +128,7 @@ async fn attribute_value_path(ctx: &mut DalContext) -> Result<()> {
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn update_object_multiplayer(ctx: &mut DalContext) -> Result<()> {
     // Create a variant that will be in all three change sets
     variant::create(

lib/dal/tests/integration_test/attribute_value/subscription.rs

@@ -27,7 +27,7 @@ use si_id::ComponentId;
 pub mod default_subscriptions;
 
 // AV subscribes to name AV on same component
-#[test]
+#[test(enable_veritech)]
 async fn subscribe_to_name_on_same_component(ctx: &mut DalContext) -> Result<()> {
     // Make a variant with a Value prop
     variant::create(
@@ -75,7 +75,7 @@ async fn subscribe_to_name_on_same_component(ctx: &mut DalContext) -> Result<()>
 }
 
 // AV subscribes to AV on same component
-#[test]
+#[test(enable_veritech)]
 async fn subscribe_to_string(ctx: &mut DalContext) -> Result<()> {
     create_testy_variant(ctx).await?;
 
@@ -118,7 +118,7 @@ async fn subscribe_to_string(ctx: &mut DalContext) -> Result<()> {
 }
 
 // AV subscribes to array element of another AV
-#[test]
+#[test(enable_veritech)]
 async fn subscribe_to_array_element(ctx: &mut DalContext) -> Result<()> {
     create_testy_variant(ctx).await?;
 
@@ -164,7 +164,7 @@ async fn subscribe_to_array_element(ctx: &mut DalContext) -> Result<()> {
 }
 
 // AV subscribes to map element of another AV
-#[test]
+#[test(enable_veritech)]
 async fn subscribe_to_map_element(ctx: &mut DalContext) -> Result<()> {
     create_testy_variant(ctx).await?;
 
@@ -214,7 +214,7 @@ async fn subscribe_to_map_element(ctx: &mut DalContext) -> Result<()> {
 }
 
 // Two different subscriptions to different values on the same component (tests dirty logic)
-#[test]
+#[test(enable_veritech)]
 async fn subscribe_to_two_values(ctx: &mut DalContext) -> Result<()> {
     create_testy_variant(ctx).await?;
 
@@ -275,7 +275,7 @@ async fn subscribe_to_two_values(ctx: &mut DalContext) -> Result<()> {
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn delete_component_with_subscriptions_correction(ctx: &mut DalContext) -> Result<()> {
     create_testy_variant(ctx).await?;
 
@@ -332,7 +332,7 @@ async fn delete_component_with_subscriptions_correction(ctx: &mut DalContext) ->
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn array_subscription(ctx: &mut DalContext) -> Result<()> {
     create_testy_variant(ctx).await?;
 
@@ -367,7 +367,7 @@ async fn array_subscription(ctx: &mut DalContext) -> Result<()> {
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn array_item_subscriptions(ctx: &mut DalContext) -> Result<()> {
     create_testy_variant(ctx).await?;
 
@@ -411,7 +411,7 @@ async fn array_item_subscriptions(ctx: &mut DalContext) -> Result<()> {
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn subscription_object_to_map(ctx: &mut DalContext) -> Result<()> {
     create_testy_variant(ctx).await?;
 
@@ -443,7 +443,7 @@ async fn subscription_object_to_map(ctx: &mut DalContext) -> Result<()> {
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn subscription_map_to_object(ctx: &mut DalContext) -> Result<()> {
     create_testy_variant(ctx).await?;
 
@@ -475,7 +475,7 @@ async fn subscription_map_to_object(ctx: &mut DalContext) -> Result<()> {
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn subscription_json_to_string(ctx: &mut DalContext) -> Result<()> {
     create_testy_variant(ctx).await?;
 
@@ -502,7 +502,7 @@ async fn subscription_json_to_string(ctx: &mut DalContext) -> Result<()> {
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn subscription_string_to_json(ctx: &mut DalContext) -> Result<()> {
     create_testy_variant(ctx).await?;
 
@@ -529,7 +529,7 @@ async fn subscription_string_to_json(ctx: &mut DalContext) -> Result<()> {
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn subscription_type_mismatch_array_to_single(ctx: &mut DalContext) -> Result<()> {
     create_testy_variant(ctx).await?;
 
@@ -554,7 +554,7 @@ async fn subscription_type_mismatch_array_to_single(ctx: &mut DalContext) -> Res
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn subscription_type_mismatch_single_to_array(ctx: &mut DalContext) -> Result<()> {
     create_testy_variant(ctx).await?;
 
@@ -579,7 +579,7 @@ async fn subscription_type_mismatch_single_to_array(ctx: &mut DalContext) -> Res
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn delete_subscribed_to_array_item(ctx: &mut DalContext) -> Result<()> {
     create_testy_variant(ctx).await?;
 
@@ -634,7 +634,7 @@ async fn delete_subscribed_to_array_item(ctx: &mut DalContext) -> Result<()> {
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn subscribe_with_custom_function(ctx: &mut DalContext) -> Result<()> {
     create_testy_variant(ctx).await?;
     let func = FuncAuthoringClient::create_new_transformation_func(
@@ -692,7 +692,7 @@ async fn subscribe_with_custom_function(ctx: &mut DalContext) -> Result<()> {
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn remove_subscribed_component(ctx: &mut DalContext) -> Result<()> {
     create_testy_variant(ctx).await?;
 
@@ -738,7 +738,7 @@ async fn remove_subscribed_component(ctx: &mut DalContext) -> Result<()> {
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn subscription_cycles(ctx: &mut DalContext) -> Result<()> {
     create_testy_variant(ctx).await?;
     component::create(ctx, "testy", "subscriber").await?;
@@ -863,7 +863,7 @@ fn extract_edges(graph: &SubscriptionGraph) -> BTreeSet<(ComponentId, ComponentI
     edges
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn subscription_graph_constructors_produce_identical_results(
     ctx: &mut DalContext,
 ) -> Result<()> {

lib/dal/tests/integration_test/attribute_value/subscription/default_subscriptions.rs

@@ -30,7 +30,7 @@ use dal_test::{
 };
 use pretty_assertions_sorted::assert_eq;
 
-#[test]
+#[test(enable_veritech)]
 async fn test_set_as_default_subscription_source(ctx: &DalContext) -> Result<()> {
     let (_, _, default_dest_a_variant_id, _) = variants_with_prop_suggestions(ctx).await?;
 
@@ -234,7 +234,7 @@ async fn test_set_as_default_subscription_source(ctx: &DalContext) -> Result<()>
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn test_is_same_type_as(ctx: &DalContext) -> Result<()> {
     variants_with_prop_suggestions(ctx).await?;
 

lib/dal/tests/integration_test/attributes.rs

@@ -41,7 +41,7 @@ use si_events::{
 
 // Test that updating attributes sets them (and their parents) correctly, but leaves default
 // values and other values alone.
-#[test]
+#[test(enable_veritech)]
 async fn update_attributes(ctx: &DalContext) -> Result<()> {
     variant::create(
         ctx,
@@ -131,7 +131,7 @@ async fn update_attributes(ctx: &DalContext) -> Result<()> {
 
 // Test that updating an attribute value via the new subscription interface correctly enqueues
 // update actions
-#[test]
+#[test(enable_veritech)]
 async fn update_attributes_enqueues_update_fn(ctx: &mut DalContext) -> Result<()> {
     // ======================================================
     // Creating a component  should enqueue a create action
@@ -229,7 +229,7 @@ async fn update_attributes_enqueues_update_fn(ctx: &mut DalContext) -> Result<()
 
 // Test that attribute updates are processed in the order they are specified sets them (and their parents) correctly, but leaves default
 // values and other values alone.
-#[test]
+#[test(enable_veritech)]
 async fn update_attributes_runs_in_order_and_allows_duplicates(ctx: &mut DalContext) -> Result<()> {
     variant::create(
         ctx,
@@ -282,7 +282,7 @@ async fn update_attributes_runs_in_order_and_allows_duplicates(ctx: &mut DalCont
     Ok(())
 }
 
-#[test]
+#[test(enable_veritech)]
 async fn update_attributes_serializes_json(ctx: &mut DalContext) -> Result<()> {
     variant::create(
         ctx,
@@ -357,7 +357,7 @@ async fn update_attributes_serializes_json(ctx: &mut DalContext) -> Result<()> {
 
 // Test that attribute updates are processed in the order they are specified sets them (and their parents) correctly, but leaves default
 // values and other values alone.
-#[test]
+#[test(enable_veritech)]
 async fn component_sources_in_order(ctx: &mut DalContext) -> Result<()> {
     variant::create(
         ctx,
@@ -495,7 +495,7 @@ async fn component_sources_in_order(ctx: &mut DalContext) -> Result<()> {
 
 // Test that updating attributes sets them (and their parents) correctly, but leaves default
 // values and other values alone.
-#[test]
+#[test(enable_veritech)]
 async fn update_attribute_child_of_subscription(ctx: &mut DalContext) -> Result<()> {
     variant::create(
         ctx,
@@ -649,7 +649,7 @@ async fn update_attribute_child_of_subscription(ctx: &mut DalContext) -> Result<
 /// This tests the fix for a bug where use_default_prototype was calling update(None)
 /// which created a si:Unset component prototype BEFORE removing the manual override,
 /// causing the component prototype to remain instead of reverting to the schema variant prototype.
-#[test]
+#[test(enable_veritech)]
 async fn unset_manual_override_reverts_to_default(ctx: &mut DalContext) -> Result<()> {
     // Create a schema with a default value
     variant::create(
@@ -732,7 +732,7 @@ async fn unset_manual_override_reverts_to_default(ctx: &mut DalContext) -> Resul
 
 /// Test that unsetting a value that was never manually overridden creates a si:Unset component prototype.
 /// This tests the else branch of use_default_prototype where no component prototype exists.
-#[test]
+#[test(enable_veritech)]
 async fn unset_value_without_existing_override_creates_unset_prototype(
     ctx: &mut DalContext,
 ) -> Result<()> {

lib/dal/tests/integration_test/audit_logging.rs

@@ -30,7 +30,7 @@ const STREAM_RETRY_INTERVAL_MILLISECONDS: u64 = 100;
 
 const SIZE: usize = 200;
 
-#[test]
+#[test(enable_veritech, enable_forklift)]
 async fn round_trip(ctx: &mut DalContext, audit_database_context: AuditDatabaseContext) {
     let context = audit_database_context;
 

lib/dal/tests/integration_test/schema/variant/authoring/clone_variant.rs → lib/dal/tests/integration_test/authoring/clone_variant.rs

@@ -7,7 +7,7 @@ use dal::{
 };
 use dal_test::test;
 
-#[test]
+#[test(enable_veritech)]
 async fn clone_variant(ctx: &mut DalContext) {
     let new_change_set = ChangeSet::fork_head(ctx, "new change set")
         .await

lib/dal/tests/integration_test/schema/variant/authoring/create_variant.rs → lib/dal/tests/integration_test/authoring/create_variant.rs

@@ -8,7 +8,7 @@ use dal::{
 };
 use dal_test::test;
 
-#[test]
+#[test(enable_veritech)]
 async fn create_variant(ctx: &mut DalContext) {
     let new_change_set = ChangeSet::fork_head(ctx, "new change set")
         .await

lib/dal/tests/integration_test/schema/variant/authoring/delete_unlocked_variant.rs → lib/dal/tests/integration_test/authoring/delete_unlocked_variant.rs

@@ -9,7 +9,7 @@ use dal_test::{
     test,
 };
 
-#[test]
+#[test(enable_veritech)]
 async fn delete_unlocked_variant(ctx: &mut DalContext) {
     let asset_name = "chainsawVariant".to_string();
     let description = None;