Update app.py

app.py

@@ -354,7 +354,7 @@ async def process_logs(file_obj, lab_site_filter, equipment_type_filter, date_ra
         else:
             df = cached_df_state
 
-        # Apply filters
+        # Apply filters for analyses other than AMC reminders
         filtered_df = df.copy()
         if lab_site_filter and lab_site_filter != 'All' and 'lab_site' in filtered_df.columns:
             filtered_df = filtered_df[filtered_df['lab_site'] == lab_site_filter]
@@ -382,7 +382,8 @@ async def process_logs(file_obj, lab_site_filter, equipment_type_filter, date_ra
         # Run critical tasks concurrently
         with ThreadPoolExecutor(max_workers=2) as executor:
             future_anomalies = executor.submit(detect_anomalies, filtered_df)
-            future_amc = executor.submit(check_amc_reminders, filtered_df, datetime.now())
+            # Use the unfiltered df for AMC reminders to avoid timestamp-based filtering
+            future_amc = executor.submit(check_amc_reminders, df, datetime.now())
 
             summary = f"Step 1: Summary Report\n{summarize_logs(filtered_df)}"
             anomalies, anomalies_df = future_anomalies.result()