|
@@ -9,7 +9,7 @@ sys.path.append(os.getcwd())
|
|
|
from common.public import task_fun_mq, get_consumer, ack_message
|
|
|
from common.scheduling_db import MysqlHelper
|
|
|
from common import AliyunLogger
|
|
|
-from zhubaisuizhihao.zhubaishuizhihao_recommend import ZhuBaiSuiZhiHaoRecommend
|
|
|
+from zhubaisuizhihao.zhubaisuizhihao_recommend import ZhuBaiSuiZhiHaoRecommend
|
|
|
|
|
|
|
|
|
def main(log_type, crawler, topic_name, group_id, env):
|