debugging - 4

metabrainz · Dec 1, 2024 · 89b8d1c · 89b8d1c
1 parent 03040da
commit 89b8d1c
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/listenbrainz_spark/request_consumer/request_consumer.py b/listenbrainz_spark/request_consumer/request_consumer.py
@@ -26,9 +26,9 @@
 from kombu.mixins import ConsumerProducerMixin
 from kombu.utils.debug import setup_logging
 
-import listenbrainz_spark
+# import listenbrainz_spark
 import listenbrainz_spark.query_map
-from listenbrainz_spark import config, hdfs_connection
+from listenbrainz_spark import config
 
 
 RABBITMQ_HEARTBEAT_TIME = 2 * 60 * 60  # 2 hours -- a full dump import takes 40 minutes right now
@@ -135,7 +135,7 @@ def start(self, app_name):
         while True:
             try:
                 logger.info('Request consumer started!')
-                listenbrainz_spark.init_spark_session(app_name)
+                # listenbrainz_spark.init_spark_session(app_name)
                 logger.info('Request consumer, spark session inited!')
                 self.init_rabbitmq_connection()
                 logger.info('Request consumer, rabbitmq connected!')