|
@@ -1,4 +1,12 @@
|
|
|
# -*- coding: utf-8 -*-
|
|
|
+import os
|
|
|
+import sys
|
|
|
+root_dir = os.path.dirname(os.path.dirname(os.path.realpath(__file__)))
|
|
|
+if root_dir not in sys.path:
|
|
|
+ sys.path.append(root_dir)
|
|
|
+ print("******** sys.path ********")
|
|
|
+ print(sys.path)
|
|
|
+
|
|
|
from odps import ODPS
|
|
|
from threading import Timer
|
|
|
import threading
|
|
@@ -9,13 +17,8 @@ import json
|
|
|
from datetime import datetime
|
|
|
from queue import Queue
|
|
|
from tqdm import tqdm
|
|
|
-import sys
|
|
|
-import os
|
|
|
-root_dir = os.path.dirname(os.path.dirname(os.path.realpath(__file__)))
|
|
|
-if root_dir not in sys.path:
|
|
|
- sys.path.append(root_dir)
|
|
|
- print("******** sys.path ********")
|
|
|
- print(sys.path)
|
|
|
+
|
|
|
+
|
|
|
|
|
|
|
|
|
config_, _ = set_config()
|