diff --git a/streamlit/sf_conn.py b/streamlit/sf_conn.py index 98dc084..199f1a5 100644 --- a/streamlit/sf_conn.py +++ b/streamlit/sf_conn.py @@ -106,7 +106,7 @@ def get_client_names(): cursor = conn.cursor() # Query to get client names and their s3_paths - query = "SELECT DISTINCT client_name, s3_bucket_path FROM STG.CLIENT_CONFIG" + query = "SELECT DISTINCT client_name, bucket_name FROM STG.CLIENT_LOGS" cursor.execute(query) # Create 2 lists from the query results client_names = [] @@ -114,7 +114,7 @@ def get_client_names(): for row in cursor: client_names.append(row[0]) - s3_paths.append(row[1].replace('s3://','').split('/')[0]) # Extracting the bucket name from the s3 path + s3_paths.append(row[1]) # Extracting the bucket name from the s3 path cursor.close() conn.close() return client_names, s3_paths