From e893b05280c485816ae1274975185615869d52a0 Mon Sep 17 00:00:00 2001 From: Anish Date: Fri, 1 Mar 2024 15:02:50 -0500 Subject: [PATCH] fix --- .../rosbag2_processing_service/main.py | 2 +- .../rosbag2_processing_service/service_manager.py | 5 ++--- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/telematic_system/telematic_historical_data_processing/rosbag2_processing_service/rosbag2_processing_service/main.py b/telematic_system/telematic_historical_data_processing/rosbag2_processing_service/rosbag2_processing_service/main.py index f28b6134..ce4eef66 100755 --- a/telematic_system/telematic_historical_data_processing/rosbag2_processing_service/rosbag2_processing_service/main.py +++ b/telematic_system/telematic_historical_data_processing/rosbag2_processing_service/rosbag2_processing_service/main.py @@ -39,7 +39,7 @@ def start_background_loop(loop: asyncio.AbstractEventLoop) -> None: main_loop = asyncio.get_event_loop() try: - main_loop.run_until_complete(service_manager.process_rosbag()) + main_loop.run_until_complete(service_manager.process_rosbag_queue()) finally: main_loop.close() diff --git a/telematic_system/telematic_historical_data_processing/rosbag2_processing_service/rosbag2_processing_service/service_manager.py b/telematic_system/telematic_historical_data_processing/rosbag2_processing_service/rosbag2_processing_service/service_manager.py index 0e6224a9..59fd0781 100644 --- a/telematic_system/telematic_historical_data_processing/rosbag2_processing_service/rosbag2_processing_service/service_manager.py +++ b/telematic_system/telematic_historical_data_processing/rosbag2_processing_service/rosbag2_processing_service/service_manager.py @@ -173,9 +173,8 @@ def update_mysql_entry(self, file_name, process_status, process_error_msg="NA"): cursor = self.mysql_conn.cursor() # Update the given tries with processing status and error msg - cursor.execute(""" - UPDATE %s SET process_status=%s, process_error_msg=%s WHERE original_filename=%s - """,(self.config.mysql_table, process_status, process_error_msg, file_name)) + query = """UPDATE {} SET process_status=%s, process_error_msg=%s WHERE original_filename=%s""".format(self.config.mysql_table) + cursor.execute(query, (process_status, process_error_msg, file_name)) self.mysql_conn.commit() self.config.logger.info(f"Updated mysql entry for {file_name} to {process_status}")