From 28fc1cf2fcc1c31feb15a0b09bdf8c6ec308c949 Mon Sep 17 00:00:00 2001 From: Albert Santoni Date: Fri, 10 Apr 2015 15:08:44 -0400 Subject: [PATCH] Fixed some airtime_analyzer unit tests --- .../airtime_analyzer/tests/analyzer_pipeline_tests.py | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/python_apps/airtime_analyzer/tests/analyzer_pipeline_tests.py b/python_apps/airtime_analyzer/tests/analyzer_pipeline_tests.py index c157b203a..8ea079847 100644 --- a/python_apps/airtime_analyzer/tests/analyzer_pipeline_tests.py +++ b/python_apps/airtime_analyzer/tests/analyzer_pipeline_tests.py @@ -21,15 +21,16 @@ def teardown(): def test_basic(): filename = os.path.basename(DEFAULT_AUDIO_FILE) - q = multiprocessing.Queue() + q = Queue.Queue() #cloud_storage_config_path = '/etc/airtime-saas/production/cloud_storage.conf' #cloud_storage_config = config_file.read_config_file(cloud_storage_config_path) cloud_storage_config = SafeConfigParser() cloud_storage_config.add_section("current_backend") cloud_storage_config.set("current_backend", "storage_backend", "file") file_prefix = u'' + storage_backend = "file" #This actually imports the file into the "./Test Artist" directory. - AnalyzerPipeline.run_analysis(q, DEFAULT_AUDIO_FILE, u'.', filename, file_prefix, cloud_storage_config) + AnalyzerPipeline.run_analysis(q, DEFAULT_AUDIO_FILE, u'.', filename, storage_backend, file_prefix, cloud_storage_config) metadata = q.get() assert metadata['track_title'] == u'Test Title' assert metadata['artist_name'] == u'Test Artist' @@ -47,13 +48,13 @@ def test_wrong_type_queue_param(): @raises(TypeError) def test_wrong_type_string_param2(): - AnalyzerPipeline.run_analysis(multiprocessing.queues.Queue(), '', u'', u'') + AnalyzerPipeline.run_analysis(Queue.Queue(), '', u'', u'') @raises(TypeError) def test_wrong_type_string_param3(): - AnalyzerPipeline.run_analysis(multiprocessing.queues.Queue(), u'', '', u'') + AnalyzerPipeline.run_analysis(Queue.Queue(), u'', '', u'') @raises(TypeError) def test_wrong_type_string_param4(): - AnalyzerPipeline.run_analysis(multiprocessing.queues.Queue(), u'', u'', '') + AnalyzerPipeline.run_analysis(Queue.Queue(), u'', u'', '')