diff --git a/pkgs/helpers/clients/txClient.go b/pkgs/helpers/clients/txClient.go
index 5ad403d..c4629a7 100644
--- a/pkgs/helpers/clients/txClient.go
+++ b/pkgs/helpers/clients/txClient.go
@@ -84,7 +84,7 @@ func SubmitSubmissionBatch(dataMarketAddress string, batchCid string, batchId st
 		EpochId:               epochId,
 		ProjectIds:            projectIds,
 		SnapshotCids:          snapshotCids,
-		FinalizedCidsRootHash: finalizedCidsRootHash,
+		FinalizedCidsRootHash: fmt.Sprintf("0x%x", finalizedCidsRootHash),
 		AuthToken:             config.SettingsObj.TxRelayerAuthWriteToken,
 	}
 
diff --git a/pkgs/helpers/prost/processor.go b/pkgs/helpers/prost/processor.go
index 9ba8e0d..77ebe73 100644
--- a/pkgs/helpers/prost/processor.go
+++ b/pkgs/helpers/prost/processor.go
@@ -178,31 +178,6 @@ func processEpoch(epochId, submissionLimit *big.Int, begin *types.Block) {
 		log.Errorln("TriggerCollectionFlow process log error: ", err.Error())
 	}
 
-	//go func(epochId *big.Int, headers []string, Day *big.Int) {
-	//	epochSizeString, err := redis.Get(context.Background(), redis.EPOCH_SIZE())
-	//	if err != nil {
-	//		log.Fatalf("Error fetching EPOCH_SIZE from redis: %s", err.Error())
-	//	}
-	//
-	//	sourceChainBlockTimeString, err := redis.Get(context.Background(), redis.SOURCE_CHAIN_BLOCK_TIME())
-	//	if err != nil {
-	//		log.Fatalf("Error fetching SOURCE_CHAIN_BLOCK_TIME from redis: %s", err.Error())
-	//	}
-	//
-	//	epochSize, err := strconv.Atoi(epochSizeString)
-	//	if err != nil {
-	//		log.Fatalf("Error converting EPOCH_SIZE to int: %s", err.Error())
-	//	}
-	//
-	//	sourceChainBlockTime, err := strconv.Atoi(sourceChainBlockTimeString)
-	//	if err != nil {
-	//		log.Fatalf("Error converting SOURCE_CHAIN_BLOCK_TIME to int: %s", err.Error())
-	//	}
-	//
-	//	time.Sleep(time.Duration(epochSize*sourceChainBlockTime) * time.Millisecond)
-	//	triggerCollectionFlow(epochId, headers, Day)
-	//}(epochId, headers, Day)
-
 	updatedDay := new(big.Int).SetUint64(((epochId.Uint64() - 1) / EpochsPerDay) + 1 + pkgs.DayBuffer) // 2828 / 10 = 282 + 1 == 283
 	if updatedDay.Cmp(Day) > 0 {
 		prev := new(big.Int).Set(Day)