From 312750712414dba231359fa4403baec75c594519 Mon Sep 17 00:00:00 2001 From: drigato Date: Tue, 3 Feb 2015 13:21:07 -0500 Subject: [PATCH] Analyzer log statements for debugging --- .../airtime_analyzer/airtime_analyzer/analyzer_pipeline.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/python_apps/airtime_analyzer/airtime_analyzer/analyzer_pipeline.py b/python_apps/airtime_analyzer/airtime_analyzer/analyzer_pipeline.py index 682afb2d3..94bc00038 100644 --- a/python_apps/airtime_analyzer/airtime_analyzer/analyzer_pipeline.py +++ b/python_apps/airtime_analyzer/airtime_analyzer/analyzer_pipeline.py @@ -42,6 +42,7 @@ class AnalyzerPipeline: AnalyzerPipeline.python_logger_deadlock_workaround() try: + logging.info("111") if not isinstance(queue, multiprocessing.queues.Queue): raise TypeError("queue must be a multiprocessing.Queue()") if not isinstance(audio_file_path, unicode): @@ -61,6 +62,7 @@ class AnalyzerPipeline: metadata = CuePointAnalyzer.analyze(audio_file_path, metadata) metadata = ReplayGainAnalyzer.analyze(audio_file_path, metadata) metadata = PlayabilityAnalyzer.analyze(audio_file_path, metadata) + logging.info("222") csu = CloudStorageUploader() @@ -70,6 +72,7 @@ class AnalyzerPipeline: metadata = FileMoverAnalyzer.move(audio_file_path, import_directory, original_filename, metadata) metadata["import_status"] = 0 # Successfully imported + logging.info("333") # Note that the queue we're putting the results into is our interprocess communication # back to the main process. @@ -77,6 +80,7 @@ class AnalyzerPipeline: # Pass all the file metadata back to the main analyzer process, which then passes # it back to the Airtime web application. queue.put(metadata) + logging.info("444") except UnplayableFileError as e: logging.exception(e) metadata["import_status"] = 2