search

cocofree / azkaban_assistant

azkaban小助手,增加任务web配置、远程脚本调用、报警扩展、跨项目依赖等功能。
Apache License 2.0
118 stars 50 forks source link

在任务配置界面中新增的job没有同步到azkaban的Job中 #10

Open wuchenlv1988 opened 6 years ago

wuchenlv1988 commented 6 years ago

我在任务配置中新增了个job，没有同步到az的Job中，日志如下

2017-08-03 10:15:51,701 - job_to_update.py[line:71] - INFO - to update job [] 2017-08-03 10:15:51,702 - web.py[line:1514] - INFO - 200 POST /job_to_update (172.29.30.105) 9.29ms 2017-08-03 10:15:51,748 - web.py[line:1514] - INFO - 304 GET /static/js/bootstrap-suggest.min.js (172.29.30.105) 0.71ms 2017-08-03 10:15:56,079 - job_check_exist.py[line:32] - INFO - ----name:[TEST1111] 2017-08-03 10:15:56,082 - web.py[line:1514] - INFO - 200 POST /job_check_exist (172.29.30.105) 3.23ms 2017-08-03 10:16:06,595 - job_update.py[line:47] - INFO - >>>>>>>>>>><type 'str'> 2017-08-03 10:16:06,595 - job_update.py[line:48] - INFO - >>>>>>>>>>> 2017-08-03 10:16:06,595 - job_update.py[line:55] - INFO - name:TEST1111 2017-08-03 10:16:06,596 - job_update.py[line:55] - INFO - project_name:TEST 2017-08-03 10:16:06,596 - job_update.py[line:55] - INFO - server_host:123 0.0.01 2017-08-03 10:16:06,596 - job_update.py[line:55] - INFO - server_user:hadoop 2017-08-03 10:16:06,596 - job_update.py[line:55] - INFO - server_dir:/tmp 2017-08-03 10:16:06,596 - job_update.py[line:55] - INFO - server_script:echo &[last_date]; 2017-08-03 10:16:06,596 - job_update.py[line:55] - INFO - retries:0 2017-08-03 10:16:06,599 - job_define.py[line:266] - INFO - delete t from kk_jobs t where t.name='TEST1111'

2017-08-03 10:16:06,609 - job_define.py[line:75] - INFO - select id,name,project_name,flow_name,server_host,server_user,server_dir,server_script,dependencies,success_email,failure_email,success_sms,failure_sms,retries,creator,updater,create_time,update_time,loc,ext_dependencies from kk_jobs where 1=1 and project_name in ( select p.name from project_permissions t inner join projects p on t.project_id=p.id where (t.permissions&2>0 or t.permissions=134217728) and t.name='azkaban' ) order by update_time desc

2017-08-03 10:16:06,611 - job_update.py[line:78] - INFO - [azkaban] update job [TEST1111] 2017-08-03 10:16:06,611 - web.py[line:1514] - INFO - 200 POST /job_update (172.29.30.105) 16.74ms 2017-08-03 10:23:50,649 - job_define.py[line:75] - INFO - select id,name,project_name,flow_name,server_host,server_user,server_dir,server_script,dependencies,success_email,failure_email,success_sms,failure_sms,retries,creator,updater,create_time,update_time,loc,ext_dependencies from kk_jobs where 1=1 and project_name in ( select p.name from project_permissions t inner join projects p on t.project_id=p.id where (t.permissions&2>0 or t.permissions=134217728) and t.name='azkaban' ) order by update_time desc

2017-08-03 10:23:50,652 - job_list.py[line:54] - INFO - query job list [{'query_user': '', 'query_project_name': '', 'login_user': u'azkaban', 'session_id': u'b194cc50-a517-4f31-b900-9daab27e53c9', 'query_name': '', 'query_server_host': ''}] 2017-08-03 10:23:50,653 - web.py[line:1514] - INFO - 200 GET /job_list?session_id=b194cc50-a517-4f31-b900-9daab27e53c9&login_user=azkaban (172.29.30.105) 4.77ms

cocofree commented 6 years ago

是否有上传过？保存是不会同步的