Update pipeline.py

pipeline.py

@@ -48,6 +48,18 @@ def get_or_create_drive_folder(name, parent_id=None):
         file_metadata["parents"] = [parent_id]
     file = drive_service.files().create(body=file_metadata, fields="id").execute()
     return file["id"]
+def find_drive_file(filename, parent_id):
+    """
+    Checks if a file with the given name exists inside the specified Google Drive folder.
+    Returns the file ID if found, else None.
+    """
+    query = f"'{parent_id}' in parents and name = '{filename}' and trashed = false"
+    results = drive_service.files().list(q=query, spaces='drive', fields='files(id, name)', pageSize=1).execute()
+    files = results.get('files', [])
+    if files:
+        return files[0]["id"]
+    return None
+
 
 def upload_file_to_drive(local_path, remote_name, folder_id):
     file_metadata = {"name": remote_name, "parents": [folder_id]}