fix: fire and forget update tx

The old behaviour causes the exporter not to publishing prices
regularly. This change spawns a separate thread to unblock the exporter
loop. Also, because of the batch staggering behaviour to avoid calling
rpc for all batches at the same time, the old approach would always
results in waiting longer than the publishing period.

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "pyth-agent"
-version = "2.4.3"
+version = "2.4.4"
 edition = "2021"
 
 [[bin]]

src/agent/solana/exporter.rs

@@ -61,6 +61,7 @@ use {
             BTreeMap,
             HashMap,
         },
+        sync::Arc,
         time::Duration,
     },
     tokio::{
@@ -228,7 +229,7 @@ pub fn spawn_exporter(
 /// Exporter is responsible for exporting data held in the local store
 /// to the global Pyth Network.
 pub struct Exporter {
-    rpc_client: RpcClient,
+    rpc_client: Arc<RpcClient>,
 
     config: Config,
 
@@ -292,7 +293,10 @@ impl Exporter {
     ) -> Self {
         let publish_interval = time::interval(config.publish_interval_duration);
         Exporter {
-            rpc_client: RpcClient::new_with_timeout(rpc_url.to_string(), rpc_timeout),
+            rpc_client: Arc::new(RpcClient::new_with_timeout(
+                rpc_url.to_string(),
+                rpc_timeout,
+            )),
             config,
             network,
             publish_interval,
@@ -796,19 +800,27 @@ impl Exporter {
             network_state.blockhash,
         );
 
-        let signature = self
-            .rpc_client
-            .send_transaction_with_config(
-                &transaction,
-                RpcSendTransactionConfig {
-                    skip_preflight: true,
-                    ..RpcSendTransactionConfig::default()
-                },
-            )
-            .await?;
-        debug!(self.logger, "sent upd_price transaction"; "signature" => signature.to_string(), "instructions" => instructions.len(), "price_accounts" => format!("{:?}", price_accounts));
-
-        self.inflight_transactions_tx.send(signature).await?;
+        let tx = self.inflight_transactions_tx.clone();
+        let logger = self.logger.clone();
+        let rpc_client = self.rpc_client.clone();
+
+        // Fire this off in a separate task so we don't block the main thread of the exporter
+        tokio::spawn(async move {
+            let signature = rpc_client
+                .send_transaction_with_config(
+                    &transaction,
+                    RpcSendTransactionConfig {
+                        skip_preflight: true,
+                        ..RpcSendTransactionConfig::default()
+                    },
+                )
+                .await
+                .unwrap();
+
+            debug!(logger, "sent upd_price transaction"; "signature" => signature.to_string(), "instructions" => instructions.len(), "price_accounts" => format!("{:?}", price_accounts));
+
+            tx.send(signature).await.unwrap();
+        });
 
         Ok(())
     }