fix

usdot-fhwa-stol · Mar 1, 2024 · e893b05 · e893b05
1 parent b9f2aaa
commit e893b05
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/..._historical_data_processing/rosbag2_processing_service/rosbag2_processing_service/main.py b/..._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/..._data_processing/rosbag2_processing_service/rosbag2_processing_service/service_manager.py b/..._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}")