From 89b8d1cbe2386d89149b28787cfdb7632c494262 Mon Sep 17 00:00:00 2001 From: Kartik Ohri Date: Sun, 1 Dec 2024 18:42:09 +0530 Subject: [PATCH] debugging - 4 --- listenbrainz_spark/request_consumer/request_consumer.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/listenbrainz_spark/request_consumer/request_consumer.py b/listenbrainz_spark/request_consumer/request_consumer.py index e84213bbb5..61c7458bca 100644 --- 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!')