diff --git a/src/index.ts b/src/index.ts
index f050f5d..b8f14a9 100644
--- a/src/index.ts
+++ b/src/index.ts
@@ -147,23 +147,32 @@ const initializeAllMarketSubscribers = async (driftClient: DriftClient) => {
 		};
 
 		if (market.phoenixMarket) {
-			const phoenixSubscriber = getPhoenixSubscriber(
-				driftClient,
-				market,
-				sdkConfig
-			);
-			await phoenixSubscriber.subscribe();
-			markets[market.marketIndex].phoenix = phoenixSubscriber;
+			const phoenixConfigAccount =
+				await driftClient.getPhoenixV1FulfillmentConfig(market.phoenixMarket);
+			if (isVariant(phoenixConfigAccount.status, 'enabled')) {
+				const phoenixSubscriber = getPhoenixSubscriber(
+					driftClient,
+					market,
+					sdkConfig
+				);
+				await phoenixSubscriber.subscribe();
+				markets[market.marketIndex].phoenix = phoenixSubscriber;
+			}
 		}
 
 		if (market.serumMarket) {
-			const serumSubscriber = getSerumSubscriber(
-				driftClient,
-				market,
-				sdkConfig
+			const serumConfigAccount = await driftClient.getSerumV3FulfillmentConfig(
+				market.serumMarket
 			);
-			await serumSubscriber.subscribe();
-			markets[market.marketIndex].serum = serumSubscriber;
+			if (isVariant(serumConfigAccount.status, 'enabled')) {
+				const serumSubscriber = getSerumSubscriber(
+					driftClient,
+					market,
+					sdkConfig
+				);
+				await serumSubscriber.subscribe();
+				markets[market.marketIndex].serum = serumSubscriber;
+			}
 		}
 	}