|
@@ -1,7 +1,6 @@
|
|
|
# -*- coding: utf-8 -*-
|
|
# -*- coding: utf-8 -*-
|
|
|
from odps import ODPS
|
|
from odps import ODPS
|
|
|
import argparse
|
|
import argparse
|
|
|
-from collections.abc import Iterable
|
|
|
|
|
|
|
|
|
|
ODPS_CONFIG = {
|
|
ODPS_CONFIG = {
|
|
|
'ENDPOINT': 'http://service.cn.maxcompute.aliyun.com/api',
|
|
'ENDPOINT': 'http://service.cn.maxcompute.aliyun.com/api',
|
|
@@ -42,10 +41,10 @@ def check_origin_hive(args):
|
|
|
partition = args.partition
|
|
partition = args.partition
|
|
|
count = check_data(project, table, partition)
|
|
count = check_data(project, table, partition)
|
|
|
if count == 0:
|
|
if count == 0:
|
|
|
- print("上游未就绪，返回1")
|
|
|
|
|
|
|
+ print("1")
|
|
|
exit(1)
|
|
exit(1)
|
|
|
else:
|
|
else:
|
|
|
- print("上游已就绪，返回0")
|
|
|
|
|
|
|
+ print("0")
|
|
|
|
|
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
if __name__ == '__main__':
|
zhangbo