diff --git a/protocol-units/execution/fin-view/src/fin_view.rs b/protocol-units/execution/fin-view/src/fin_view.rs index f44a4b2ec..0dd08f5f2 100644 --- a/protocol-units/execution/fin-view/src/fin_view.rs +++ b/protocol-units/execution/fin-view/src/fin_view.rs @@ -78,7 +78,8 @@ mod tests { let config = Config::default(); let (tx_sender, _tx_receiver) = mpsc::channel(16); let executor = Executor::try_from_config(&config)?; - let (context, _transaction_pipe) = executor.background(tx_sender, &config)?; + let (context, _transaction_pipe, _indexer_runtime) = + executor.background(tx_sender, &config)?; let finality_view = FinalityView::new(context.db_reader()); let service = finality_view.service( context.mempool_client_sender(), diff --git a/protocol-units/execution/opt-executor/src/executor/execution.rs b/protocol-units/execution/opt-executor/src/executor/execution.rs index 890647501..73c172dcc 100644 --- a/protocol-units/execution/opt-executor/src/executor/execution.rs +++ b/protocol-units/execution/opt-executor/src/executor/execution.rs @@ -265,7 +265,8 @@ mod tests { let private_key = Ed25519PrivateKey::generate_for_testing(); let (tx_sender, _tx_receiver) = mpsc::channel(1); let (executor, config, _tempdir) = Executor::try_test_default(private_key)?; - let (context, _transaction_pipe) = executor.background(tx_sender, &config)?; + let (context, _transaction_pipe, _indexer_runtime) = + executor.background(tx_sender, &config)?; let block_id = HashValue::random(); let block_metadata = Transaction::BlockMetadata(BlockMetadata::new( block_id, @@ -299,7 +300,8 @@ mod tests { let private_key = Ed25519PrivateKey::generate_for_testing(); let (tx_sender, _tx_receiver) = mpsc::channel(1); let (executor, config, _tempdir) = Executor::try_test_default(private_key)?; - let (context, _transaction_pipe) = executor.background(tx_sender, &config)?; + let (context, _transaction_pipe, _indexer_runtime) = + executor.background(tx_sender, &config)?; executor.rollover_genesis_now().await?; // Initialize a root account using a predefined keypair and the test root address. @@ -401,7 +403,8 @@ mod tests { let private_key = Ed25519PrivateKey::generate_for_testing(); let (tx_sender, _tx_receiver) = mpsc::channel(16); let (executor, config, _tempdir) = Executor::try_test_default(private_key)?; - let (context, _transaction_pipe) = executor.background(tx_sender, &config)?; + let (context, _transaction_pipe, _indexer_runtime) = + executor.background(tx_sender, &config)?; let service = Service::new(&context); executor.rollover_genesis_now().await?; diff --git a/protocol-units/execution/opt-executor/src/service.rs b/protocol-units/execution/opt-executor/src/service.rs index 0c55d88c3..fea2750b3 100644 --- a/protocol-units/execution/opt-executor/src/service.rs +++ b/protocol-units/execution/opt-executor/src/service.rs @@ -116,7 +116,8 @@ mod tests { async fn test_pipe_mempool_while_server_running() -> Result<(), anyhow::Error> { let (tx_sender, mut tx_receiver) = mpsc::channel(16); let (executor, config, _tempdir) = Executor::try_test_default(GENESIS_KEYPAIR.0.clone())?; - let (context, mut transaction_pipe) = executor.background(tx_sender, &config)?; + let (context, mut transaction_pipe, _indexer_runtime) = + executor.background(tx_sender, &config)?; let service = Service::new(&context); let handle = tokio::spawn(async move { service.run().await }); diff --git a/protocol-units/execution/opt-executor/src/transaction_pipe.rs b/protocol-units/execution/opt-executor/src/transaction_pipe.rs index b5a3fa0b4..1ae50bad0 100644 --- a/protocol-units/execution/opt-executor/src/transaction_pipe.rs +++ b/protocol-units/execution/opt-executor/src/transaction_pipe.rs @@ -200,7 +200,8 @@ mod tests { let (tx_sender, tx_receiver) = mpsc::channel(16); let (executor, config, _tempdir) = Executor::try_test_default(GENESIS_KEYPAIR.0.clone()).unwrap(); - let (context, transaction_pipe) = executor.background(tx_sender, &config).unwrap(); + let (context, transaction_pipe, _indexer_runtime) = + executor.background(tx_sender, &config).unwrap(); (transaction_pipe, context.mempool_client_sender(), tx_receiver) } @@ -309,7 +310,8 @@ mod tests { async fn test_pipe_mempool_from_api() -> Result<(), anyhow::Error> { let (tx_sender, mut tx_receiver) = mpsc::channel(16); let (executor, config, _tempdir) = Executor::try_test_default(GENESIS_KEYPAIR.0.clone())?; - let (context, mut transaction_pipe) = executor.background(tx_sender, &config)?; + let (context, mut transaction_pipe, _indexer_runtime) = + executor.background(tx_sender, &config)?; let service = Service::new(&context); #[allow(unreachable_code)] @@ -338,7 +340,8 @@ mod tests { async fn test_repeated_pipe_mempool_from_api() -> Result<(), anyhow::Error> { let (tx_sender, mut tx_receiver) = mpsc::channel(16); let (executor, config, _tempdir) = Executor::try_test_default(GENESIS_KEYPAIR.0.clone())?; - let (context, mut transaction_pipe) = executor.background(tx_sender, &config)?; + let (context, mut transaction_pipe, _indexer_runtime) = + executor.background(tx_sender, &config)?; let service = Service::new(&context); #[allow(unreachable_code)]