1 files changed, 1 insertions, 4 deletions
diff --git a/packages/pipeline/src/data_sources/bloxy/index.ts b/packages/pipeline/src/data_sources/bloxy/index.ts
index 68764ca98..22ab195b3 100644
--- a/packages/pipeline/src/data_sources/bloxy/index.ts
+++ b/packages/pipeline/src/data_sources/bloxy/index.ts
@@ -78,10 +78,7 @@ export class BloxySource {
     public async getDexTradesAsync(lastSeenTimestamp: number): Promise<BloxyTrade[]> {
         const allTrades = await this._scrapeAllDexTradesAsync(lastSeenTimestamp);
         logUtils.log(`Removing duplicates from ${allTrades.length} entries`);
-        const uniqueTrades = R.uniqBy(
-            (trade: BloxyTrade) => `${trade.tradeIndex}-${trade.tx_hash}`,
-            allTrades,
-        ) as BloxyTrade[];
+        const uniqueTrades = R.uniqBy((trade: BloxyTrade) => `${trade.tradeIndex}-${trade.tx_hash}`, allTrades);
         logUtils.log(`Removed ${allTrades.length - uniqueTrades.length} duplicate entries`);
         return uniqueTrades;
     }