Update app.py

app.py

@@ -1,5 +1,5 @@
 """
-LabOps Log Analyzer Dashboard with CSV file upload, PDF generation, Salesforce integration, and AMC reminder via Salesforce trigger
+LabOps Log Analyzer Dashboard with CSV file upload, PDF generation, and backend Salesforce integration
 """
 import gradio as gr
 import pandas as pd
@@ -94,7 +94,7 @@ picklist_mapping = {
         'maintenance': 'Smart Log',
         'cell': 'Cell Analysis',
         'uv': 'UV Verification',
-        'weight log': 'Smart Log'  # Added mapping for 'weight log'
+        'weight log': 'Smart Log'
     }
 }
 
@@ -119,12 +119,14 @@ def get_folder_id(folder_name):
 # Cache the folder ID at startup
 LABOPS_REPORTS_FOLDER_ID = get_folder_id('LabOps Reports')
 
-# Updated Salesforce report creation with minimal metadata
+# Salesforce report creation (runs in backend, result not displayed)
 def create_salesforce_reports(df):
     if sf is None:
-        return "Salesforce connection not available."
+        logging.info("Salesforce connection not available for report creation.")
+        return
     if not LABOPS_REPORTS_FOLDER_ID:
-        return "Cannot create reports: 'LabOps Reports' folder not found in Salesforce."
+        logging.info("Cannot create reports: 'LabOps Reports' folder not found in Salesforce.")
+        return
 
     try:
         # Usage Report (Tabular Report for simplicity)
@@ -164,16 +166,14 @@ def create_salesforce_reports(df):
         amc_result = sf.restful('analytics/reports', method='POST', json=amc_report_metadata)
         amc_report_id = amc_result['id']
         logging.info(f"AMC Reminders Report created: {amc_report_id}")
-
-        return f"Usage Report ID: {usage_report_id}, AMC Reminders Report ID: {amc_report_id}"
     except Exception as e:
         logging.error(f"Failed to create Salesforce reports: {str(e)}")
-        return f"Failed to create reports: {str(e)}"
 
-# Save results to Salesforce SmartLog__c
+# Save results to Salesforce SmartLog__c (runs in backend, result not displayed)
 def save_to_salesforce(df, summary, anomalies, amc_reminders, insights):
     if sf is None:
-        return "Salesforce connection not available."
+        logging.info("Salesforce connection not available for saving records.")
+        return
     try:
         records = []
         current_date = datetime.now()
@@ -232,10 +232,8 @@ def save_to_salesforce(df, summary, anomalies, amc_reminders, insights):
         if records:
             sf.bulk.SmartLog__c.insert(records)
             logging.info(f"Saved {len(records)} records to Salesforce")
-        return f"Saved {len(records)} records to Salesforce."
     except Exception as e:
         logging.error(f"Failed to save to Salesforce: {str(e)}")
-        return f"Failed to save to Salesforce: {str(e)}"
 
 # Summarize logs
 def summarize_logs(df):
@@ -335,7 +333,7 @@ def create_usage_chart(df):
         logging.error(f"Failed to create usage chart: {str(e)}")
         return None
 
-# Generate PDF content (removed email_status since email is handled by Salesforce)
+# Generate PDF content
 def generate_pdf_content(summary, preview, anomalies, amc_reminders, insights):
     if not reportlab_available:
         return None
@@ -383,13 +381,13 @@ async def process_logs(file_obj):
     try:
         start_time = datetime.now()
         if not file_obj:
-            return "No file uploaded.", "No data to preview.", None, "No anomalies detected.", "No AMC reminders.", "No insights generated.", None, "No Salesforce data saved.", "No report created."
+            return "No file uploaded.", "No data to preview.", None, "No anomalies detected.", "No AMC reminders.", "No insights generated.", None
 
         file_name = file_obj.name
         logging.info(f"Processing file: {file_name}")
         
         if not file_name.endswith(".csv"):
-            return "Please upload a CSV file.", "", None, "", "", "", None, "", ""
+            return "Please upload a CSV file.", "", None, "", "", "", None
 
         required_columns = ["device_id", "log_type", "status", "timestamp", "usage_hours", "downtime", "amc_date"]
         dtypes = {
@@ -403,11 +401,11 @@ async def process_logs(file_obj):
         df = pd.read_csv(file_obj, dtype=dtypes)
         missing_columns = [col for col in required_columns if col not in df.columns]
         if missing_columns:
-            return f"Missing columns: {missing_columns}", None, None, None, None, None, None, None, None
+            return f"Missing columns: {missing_columns}", None, None, None, None, None, None
         df["timestamp"] = pd.to_datetime(df["timestamp"], errors='coerce')
         df["amc_date"] = pd.to_datetime(df["amc_date"], errors='coerce')
         if df.empty:
-            return "No data available.", None, None, None, None, None, None, None, None
+            return "No data available.", None, None, None, None, None, None
 
         # Run tasks concurrently
         with ThreadPoolExecutor(max_workers=4) as executor:
@@ -424,7 +422,6 @@ async def process_logs(file_obj):
             amc_reminders = f"AMC Reminders\n{amc_reminders}"
             insights = f"Dashboard Insights (AI)\n{future_insights.result()}"
             chart = future_chart.result()
-            report_result = future_reports.result()
 
         preview_lines = ["Step 2: Log Preview (First 5 Rows)"]
         for idx, row in df.head(5).iterrows():
@@ -436,15 +433,16 @@ async def process_logs(file_obj):
             )
         preview = "\n".join(preview_lines)
 
-        salesforce_result = save_to_salesforce(df, summary, anomalies, amc_reminders, insights)
+        # Save to Salesforce in the backend
+        save_to_salesforce(df, summary, anomalies, amc_reminders, insights)
         pdf_file = generate_pdf_content(summary, preview, anomalies, amc_reminders, insights)
 
         elapsed_time = (datetime.now() - start_time).total_seconds()
-        logging.info(f"Processing completed in {elapsed_time:.2f} seconds")
-        return summary, preview, chart, anomalies, amc_reminders, insights, pdf_file, salesforce_result, report_result
+        logging.info(f"Processing completed in {elapsed_time:.2f} secondsIS")
+        return summary, preview, chart, anomalies, amc_reminders, insights, pdf_file
     except Exception as e:
         logging.error(f"Failed to process file: {str(e)}")
-        return f"Error: {str(e)}", None, None, None, None, None, None, None, None
+        return f"Error: {str(e)}", None, None, None, None, None, None
 
 # Gradio Interface
 try:
@@ -507,9 +505,7 @@ try:
                 anomaly_output,
                 amc_output,
                 insights_output,
-                pdf_output,
-                salesforce_output,
-                report_output
+                pdf_output
             ]
         )