6
6
from sqlalchemy .sql import text
7
7
8
8
from sqlalchemy .dialects .postgresql import insert
9
- from sqlalchemy import Table , MetaData
9
+ from sqlalchemy import Table , Column , Integer , String , MetaData , ForeignKey , exc , select
10
10
from pipeline import flow_script
11
11
from config import engine
12
- from flask import request , redirect , jsonify , current_app
12
+ from flask import request , redirect , jsonify , current_app , abort
13
13
from api .file_uploader import validate_and_arrange_upload
14
14
from config import (
15
15
RAW_DATA_PATH ,
16
- CURRENT_SOURCE_FILES_PATH
16
+ CURRENT_SOURCE_FILES_PATH ,
17
+ LOGS_PATH ,
17
18
)
18
19
19
20
ALLOWED_EXTENSIONS = {"csv" , "xlsx" }
@@ -30,9 +31,8 @@ def __allowed_file(filename):
30
31
# file upload tutorial
31
32
@admin_api .route ("/api/file" , methods = ["POST" ])
32
33
def uploadCSV ():
33
- current_app .logger .info ("Uploading CSV" )
34
34
if "file" not in request .files :
35
- return jsonify ({ "error" : "no file supplied" });
35
+ return redirect ( request . url )
36
36
37
37
for file in request .files .getlist ("file" ):
38
38
if __allowed_file (file .filename ):
@@ -119,10 +119,8 @@ def list_statistics():
119
119
with engine .connect () as connection :
120
120
s = text ("select valcol from kv_unique where keycol = 'last_execution_time';" )
121
121
result = connection .execute (s )
122
+ last_execution_details = result .fetchone ()[0 ]
122
123
123
- fetch_result = result .fetchone ()
124
- if fetch_result :
125
- last_execution_details = result .fetchone ()[0 ]
126
124
127
125
except Exception as e :
128
126
current_app .logger .error ("Failure reading Last Execution stats from DB" )
0 commit comments