Add run with actix to some commands (#161)

PeggyJV · Aug 25, 2021 · 14d9c31 · 14d9c31
1 parent cc91239
commit 14d9c31
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/orchestrator/gorc/src/commands/deploy/erc20.rs b/orchestrator/gorc/src/commands/deploy/erc20.rs
@@ -19,7 +19,7 @@ pub struct Erc20 {
 
 impl Runnable for Erc20 {
     fn run(&self) {
-        abscissa_tokio::run(&APP, async {
+        abscissa_tokio::run_with_actix(&APP, async {
             self.deploy().await;
         })
         .unwrap_or_else(|e| {

diff --git a/orchestrator/gorc/src/commands/tx/cosmos.rs b/orchestrator/gorc/src/commands/tx/cosmos.rs
@@ -71,7 +71,7 @@ impl Runnable for SendToEth {
         let cosmos_prefix = config.cosmos.prefix.clone();
         let cosmso_grpc = config.cosmos.grpc.clone();
 
-        abscissa_tokio::run(&APP, async {
+        abscissa_tokio::run_with_actix(&APP, async {
             let connections =
                 create_rpc_connections(cosmos_prefix, Some(cosmso_grpc), None, TIMEOUT).await;
             let contact = connections.contact.unwrap();
@@ -162,7 +162,7 @@ impl Runnable for Send {
         let _to_addr = self.free[1].clone();
         let _coin_amount = self.free[2].clone();
 
-        abscissa_tokio::run(&APP, async { unimplemented!() }).unwrap_or_else(|e| {
+        abscissa_tokio::run_with_actix(&APP, async { unimplemented!() }).unwrap_or_else(|e| {
             status_err!("executor exited with error: {}", e);
             exit(1);
         });

diff --git a/orchestrator/gorc/src/commands/tx/eth.rs b/orchestrator/gorc/src/commands/tx/eth.rs
@@ -65,7 +65,7 @@ impl Runnable for SendToCosmos {
             .parse()
             .expect("Expected config.gravity.contract to be an Eth ddress");
 
-        abscissa_tokio::run(&APP, async {
+        abscissa_tokio::run_with_actix(&APP, async {
             let connections =
                 create_rpc_connections(cosmos_prefix, Some(cosmso_grpc), Some(eth_rpc), TIMEOUT)
                     .await;