Congegni/sintonia
7
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Analyzer log statements for debugging

Browse source
This commit is contained in:
drigato 2015-02-03 13:21:07 -05:00
parent 5040eb498d
commit 3127507124
1 changed files with 4 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

4
python_apps/airtime_analyzer/airtime_analyzer/analyzer_pipeline.py
View file

@ -42,6 +42,7 @@ class AnalyzerPipeline:
AnalyzerPipeline.python_logger_deadlock_workaround() AnalyzerPipeline.python_logger_deadlock_workaround()
try: try:
logging.info("111")
if not isinstance(queue, multiprocessing.queues.Queue): if not isinstance(queue, multiprocessing.queues.Queue):
raise TypeError("queue must be a multiprocessing.Queue()") raise TypeError("queue must be a multiprocessing.Queue()")
if not isinstance(audio_file_path, unicode): if not isinstance(audio_file_path, unicode):
@ -61,6 +62,7 @@ class AnalyzerPipeline:
metadata = CuePointAnalyzer.analyze(audio_file_path, metadata) metadata = CuePointAnalyzer.analyze(audio_file_path, metadata)
metadata = ReplayGainAnalyzer.analyze(audio_file_path, metadata) metadata = ReplayGainAnalyzer.analyze(audio_file_path, metadata)
metadata = PlayabilityAnalyzer.analyze(audio_file_path, metadata) metadata = PlayabilityAnalyzer.analyze(audio_file_path, metadata)
logging.info("222")
csu = CloudStorageUploader() csu = CloudStorageUploader()
@ -70,6 +72,7 @@ class AnalyzerPipeline:
metadata = FileMoverAnalyzer.move(audio_file_path, import_directory, original_filename, metadata) metadata = FileMoverAnalyzer.move(audio_file_path, import_directory, original_filename, metadata)
metadata["import_status"] = 0 # Successfully imported metadata["import_status"] = 0 # Successfully imported
logging.info("333")
# Note that the queue we're putting the results into is our interprocess communication # Note that the queue we're putting the results into is our interprocess communication
# back to the main process. # 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 # Pass all the file metadata back to the main analyzer process, which then passes
# it back to the Airtime web application. # it back to the Airtime web application.
queue.put(metadata) queue.put(metadata)
logging.info("444")
except UnplayableFileError as e: except UnplayableFileError as e:
logging.exception(e) logging.exception(e)
metadata["import_status"] = 2 metadata["import_status"] = 2