Skip to content

Commit 96c396f

Browse files
committed
fileId类型变更
1 parent d6c18fb commit 96c396f

3 files changed

Lines changed: 4 additions & 4 deletions

File tree

runtime/python-executor/data_platform/sqlite_manager/persistence_atction.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -34,9 +34,9 @@ def persistence_task_info(self, sample: Dict[str, Any]):
3434
instance_id = str(sample.get("instance_id"))
3535
meta_file_name = str(sample.get("sourceFileName"))
3636
meta_file_type = str(sample.get("sourceFileType"))
37-
meta_file_id = int(sample.get("sourceFileId"))
37+
meta_file_id = str(sample.get("sourceFileId"))
3838
meta_file_size = str(sample.get("sourceFileSize"))
39-
file_id = int(sample.get("fileId"))
39+
file_id = str(sample.get("fileId"))
4040
file_size = str(sample.get("fileSize"))
4141
file_type = str(sample.get("fileType"))
4242
file_name = str(sample.get("fileName"))

runtime/python-executor/data_platform/sqlite_manager/sql/sql_config.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,6 @@
22
"query_sql": "SELECT * FROM task_instance_info WHERE instance_id = ?",
33
"db_path": "/flow/sqlite.db",
44
"insert_sql": "INSERT INTO task_instance_info (instance_id, meta_file_name, meta_file_type, meta_file_id, meta_file_size, file_id, file_size, file_type, file_name, file_path, source_file_modify_time, status, operator_id, error_code, incremental, childId, slice_num) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)",
5-
"create_tables_sql": "CREATE TABLE IF NOT EXISTS task_instance_info (instance_id TEXT, meta_file_name TEXT, meta_file_type TEXT, meta_file_id INTEGER, meta_file_size TEXT, file_id INTEGER, file_size TEXT, file_type TEXT, file_name TEXT, file_path TEXT, source_file_modify_time INTEGER, status INTEGER, operator_id TEXT, error_code TEXT, incremental TEXT, childId INTEGER, slice_num INTEGER DEFAULT 0)",
5+
"create_tables_sql": "CREATE TABLE IF NOT EXISTS task_instance_info (instance_id TEXT, meta_file_name TEXT, meta_file_type TEXT, meta_file_id TEXT, meta_file_size TEXT, file_id TEXT, file_size TEXT, file_type TEXT, file_name TEXT, file_path TEXT, source_file_modify_time INTEGER, status INTEGER, operator_id TEXT, error_code TEXT, incremental TEXT, childId INTEGER, slice_num INTEGER DEFAULT 0)",
66
"delete_task_instance_sql": "DELETE FROM task_instance_info WHERE instance_id = ?"
77
}

scripts/images/frontend/edm.conf

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,6 @@ server {
1111

1212
location / {
1313
root /opt/frontend;
14-
index index.html index.htm;
14+
try_files $uri $uri/ /index.html;
1515
}
1616
}

0 commit comments

Comments
 (0)