Update app.py

app.py

@@ -170,20 +170,33 @@ def update_record(container, updated_record):
     except Exception as e:
         return False, f"Error: {traceback.format_exc()} 😱"
 
-# 🗑️ Delete record – now explicitly catches resource not found errors
+# 🗑️ Delete record – query first, then delete using the actual partition key
 def delete_record(container, record):
     try:
-        container.delete_item(item=record['id'], partition_key=record['id'])
-        return True, f"Record {record['id']} successfully deleted. 🗑️"
-    except exceptions.CosmosResourceNotFoundError:
-        # Document does not exist – treat as deleted
-        return True, f"Record {record['id']} not found (already deleted). 🗑️"
+        # Query for the document by id to get the actual partition key value.
+        query = "SELECT * FROM c WHERE c.id=@id"
+        parameters = [{"name": "@id", "value": record["id"]}]
+        docs = list(container.query_items(
+            query=query,
+            parameters=parameters,
+            enable_cross_partition_query=True
+        ))
+        if not docs:
+            # Document doesn't exist; treat as already deleted.
+            return True, f"Record {record['id']} not found (already deleted). 🗑️"
+        
+        # Use the partition key value from the retrieved document.
+        doc = docs[0]
+        partition_key = doc.get("name")  # assuming 'name' is your partition key
+        container.delete_item(item=doc["id"], partition_key=partition_key)
+        return True, f"Record {doc['id']} successfully deleted. 🗑️"
     except exceptions.CosmosHttpResponseError as e:
         return False, f"HTTP error: {str(e)} 🚨"
     except Exception as e:
         return False, f"Unexpected error: {traceback.format_exc()} 😱"
 
 
+
 # 💾 Save a new document to Cosmos DB with extra fields
 def save_to_cosmos_db(container, query, response1, response2):
     try: