update

src/cli.ts

@@ -620,9 +620,6 @@ export const main = async (argv: any, version?: string) => {
         }
     });
 
-    // periodically fetch and set gas price in state (once every 20 seconds)
-    setInterval(() => getGasPrice(config, state), 20_000);
-
     const lastReadOrdersMap = options.subgraph.map((v) => ({
         sg: v,
         skip: 0,

src/processOrders.ts

@@ -1,6 +1,6 @@
 import { ChainId } from "sushi";
 import { findOpp } from "./modes";
-import { getQuoteGas } from "./gas";
+import { getGasPrice, getQuoteGas } from "./gas";
 import { PublicClient } from "viem";
 import { Token } from "sushi/currency";
 import { quoteSingleOrder } from "./order";
@@ -422,8 +422,6 @@ export async function processPair(args: {
             sellToken: orderPairObject.sellToken,
         },
     };
-    const gasPrice = ethers.BigNumber.from(state.gasPrice);
-
     spanAttributes["details.orders"] = orderPairObject.takeOrders.map((v) => v.id);
     spanAttributes["details.pair"] = pair;
 
@@ -471,6 +469,9 @@ export async function processPair(args: {
         ratio: ethers.utils.formatUnits(orderPairObject.takeOrders[0].quote!.ratio),
     });
 
+    await getGasPrice(config, state);
+    const gasPrice = ethers.BigNumber.from(state.gasPrice);
+
     // get pool details
     if (
         !dataFetcher.fetchedPairPools.includes(pair) ||