diff --git a/pallets/ddc-verification/src/lib.rs b/pallets/ddc-verification/src/lib.rs
index 53602ecab..75af80015 100644
--- a/pallets/ddc-verification/src/lib.rs
+++ b/pallets/ddc-verification/src/lib.rs
@@ -1532,9 +1532,11 @@ pub mod pallet {
 					PayoutState::Initialized
 				{
 					if let Some((_, _, customers_activity_batch_roots, _, _, _)) =
-						Self::fetch_validation_activities::<CustomerActivity, NodeActivity>(
-							cluster_id, era_id,
-						) {
+						Self::fetch_validation_activities::<
+							BucketNodeAggregatesActivity,
+							NodeActivity,
+						>(cluster_id, era_id)
+					{
 						Self::fetch_customer_activity(
 							cluster_id,
 							era_id,
@@ -1552,9 +1554,11 @@ pub mod pallet {
 						)?;
 
 						if let Some((_, _, customers_activity_batch_roots, _, _, _)) =
-							Self::fetch_validation_activities::<CustomerActivity, NodeActivity>(
-								cluster_id, era_id,
-							) {
+							Self::fetch_validation_activities::<
+								BucketNodeAggregatesActivity,
+								NodeActivity,
+							>(cluster_id, era_id)
+						{
 							Self::fetch_customer_activity(
 								cluster_id,
 								era_id,
@@ -1784,9 +1788,11 @@ pub mod pallet {
 						nodes_activity_in_consensus,
 						_,
 						nodes_activity_batch_roots,
-					)) = Self::fetch_validation_activities::<CustomerActivity, NodeActivity>(
-						cluster_id, era_id,
-					) {
+					)) = Self::fetch_validation_activities::<
+						BucketNodeAggregatesActivity,
+						NodeActivity,
+					>(cluster_id, era_id)
+					{
 						Self::fetch_reward_activities(
 							cluster_id,
 							era_id,
@@ -1812,9 +1818,11 @@ pub mod pallet {
 							nodes_activity_in_consensus,
 							_,
 							nodes_activity_batch_roots,
-						)) = Self::fetch_validation_activities::<CustomerActivity, NodeActivity>(
-							cluster_id, era_id,
-						) {
+						)) = Self::fetch_validation_activities::<
+							BucketNodeAggregatesActivity,
+							NodeActivity,
+						>(cluster_id, era_id)
+						{
 							Self::fetch_reward_activities(
 								cluster_id,
 								era_id,
@@ -1887,9 +1895,11 @@ pub mod pallet {
 						nodes_activity_in_consensus,
 						_,
 						nodes_activity_batch_roots,
-					)) = Self::fetch_validation_activities::<CustomerActivity, NodeActivity>(
-						cluster_id, era_id,
-					) {
+					)) = Self::fetch_validation_activities::<
+						BucketNodeAggregatesActivity,
+						NodeActivity,
+					>(cluster_id, era_id)
+					{
 						Self::fetch_reward_provider_batch(
 							cluster_id,
 							batch_size,
@@ -1915,9 +1925,11 @@ pub mod pallet {
 							nodes_activity_in_consensus,
 							_,
 							nodes_activity_batch_roots,
-						)) = Self::fetch_validation_activities::<CustomerActivity, NodeActivity>(
-							cluster_id, era_id,
-						) {
+						)) = Self::fetch_validation_activities::<
+							BucketNodeAggregatesActivity,
+							NodeActivity,
+						>(cluster_id, era_id)
+						{
 							Self::fetch_reward_provider_batch(
 								cluster_id,
 								batch_size,
@@ -2907,7 +2919,7 @@ pub mod pallet {
 			let threshold = percent * <ValidatorSet<T>>::get().len();
 
 			let mut should_deposit_ready_event = false;
-			if threshold < signed_validators.len() {
+			if threshold <= signed_validators.len() {
 				// Update payers_merkle_root_hash and payees_merkle_root_hash as ones passed the
 				// threshold
 				era_validation.payers_merkle_root_hash = payers_merkle_root_hash;
diff --git a/runtime/cere-dev/src/lib.rs b/runtime/cere-dev/src/lib.rs
index 3cbd851c7..bd87fcece 100644
--- a/runtime/cere-dev/src/lib.rs
+++ b/runtime/cere-dev/src/lib.rs
@@ -149,7 +149,7 @@ pub const VERSION: RuntimeVersion = RuntimeVersion {
 	// and set impl_version to 0. If only runtime
 	// implementation changes and behavior does not, then leave spec_version as
 	// is and increment impl_version.
-	spec_version: 54123,
+	spec_version: 54126,
 	impl_version: 0,
 	apis: RUNTIME_API_VERSIONS,
 	transaction_version: 19,
diff --git a/runtime/cere/src/lib.rs b/runtime/cere/src/lib.rs
index 0556bb8e3..bb4875a5a 100644
--- a/runtime/cere/src/lib.rs
+++ b/runtime/cere/src/lib.rs
@@ -143,7 +143,7 @@ pub const VERSION: RuntimeVersion = RuntimeVersion {
 	// and set impl_version to 0. If only runtime
 	// implementation changes and behavior does not, then leave spec_version as
 	// is and increment impl_version.
-	spec_version: 54123,
+	spec_version: 54126,
 	impl_version: 0,
 	apis: RUNTIME_API_VERSIONS,
 	transaction_version: 19,