diff options
| -rw-r--r-- | wqflask/wqflask/correlation/pre_computes.py | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/wqflask/wqflask/correlation/pre_computes.py b/wqflask/wqflask/correlation/pre_computes.py index e82eb0ec..c91e3862 100644 --- a/wqflask/wqflask/correlation/pre_computes.py +++ b/wqflask/wqflask/correlation/pre_computes.py @@ -190,12 +190,18 @@ def __generate_target_name__(db_name): f"ProbeSetFreezeId_{results[0]}_{results[1]}") -def fetch_csv_info(textfile_path: str, db_target_name: str): +def fetch_csv_info(db_target_name: str, conn): """ alternative for processing csv textfiles with rust !.currently expiremental """ - raise ValueError + csv_file_path = fetch_text_file(dataset_name, conn) + if csv_file_path: + return { + "file_type": "csv", + "lmdb_target_path": "csv_file_path", + "lmdb_target_path": "", + } def fetch_lmdb_info(db_path: str, db_target_name: str): |