| .. |
|
common.py
|
09b2edddcd
更新执行时长的功能没有成功
|
il y a 1 mois |
|
config.py
|
1e4838a523
修改pipeline_prepare代码中的支持多个版本的json文件，还未删除它把执行计划写入数据库表的功能
|
il y a 1 mois |
|
dag_data_model_daily.py
|
fbebca0978
已经完成对定时订阅功能的公共函数的优化和测试
|
il y a 1 mois |
|
dag_data_model_monthly.py
|
fbebca0978
已经完成对定时订阅功能的公共函数的优化和测试
|
il y a 1 mois |
|
dag_data_model_scheduler.py
|
954f012a2e
添加两个单独的scheduler.py,实现两级周期订阅
|
il y a 1 mois |
|
dag_data_model_weekly.py
|
fbebca0978
已经完成对定时订阅功能的公共函数的优化和测试
|
il y a 1 mois |
|
dag_data_model_yearly.py
|
fbebca0978
已经完成对定时订阅功能的公共函数的优化和测试
|
il y a 1 mois |
|
dag_data_resource.py
|
fbebca0978
已经完成对定时订阅功能的公共函数的优化和测试
|
il y a 1 mois |
|
dag_data_resource_scheduler.py
|
954f012a2e
添加两个单独的scheduler.py,实现两级周期订阅
|
il y a 1 mois |
|
dag_dataops_model_scheduler.py
|
6f291ae161
完成对dag_dataops_*_scheduler.py 四个脚本的编写，后续需要研究airflow的系统执行时间，现在不同DAG中系统执行时间不一致。
|
il y a 1 mois |
|
dag_dataops_pipeline_data_scheduler.py
|
85deb8de46
已经莫名其妙的修复了pipline_data_scheduler.py
|
il y a 1 mois |
|
dag_dataops_pipeline_prepare_scheduler.py
|
935efc4d4b
pipeline_prepare 同时把plan写成json文件和数据库表
|
il y a 1 mois |
|
dag_dataops_prepare_scheduler.py
|
6f291ae161
完成对dag_dataops_*_scheduler.py 四个脚本的编写，后续需要研究airflow的系统执行时间，现在不同DAG中系统执行时间不一致。
|
il y a 1 mois |
|
dag_dataops_resource_scheduler.py
|
6f291ae161
完成对dag_dataops_*_scheduler.py 四个脚本的编写，后续需要研究airflow的系统执行时间，现在不同DAG中系统执行时间不一致。
|
il y a 1 mois |
|
dag_dataops_summary_scheduler.py
|
6f291ae161
完成对dag_dataops_*_scheduler.py 四个脚本的编写，后续需要研究airflow的系统执行时间，现在不同DAG中系统执行时间不一致。
|
il y a 1 mois |
|
dag_dataops_unified_data_scheduler.py
|
61990f9b8d
准备把unified_data和unified_summary合并为一个DAG
|
il y a 1 mois |
|
dag_dataops_unified_prepare_scheduler.py
|
61990f9b8d
准备把unified_data和unified_summary合并为一个DAG
|
il y a 1 mois |
|
dag_dataops_unified_summary_scheduler.py
|
61990f9b8d
准备把unified_data和unified_summary合并为一个DAG
|
il y a 1 mois |
|
dag_manual_dependency_trigger.py
|
5e51972be7
单一文件的DAG我准备放弃了，目前unified三文件版本是可以正常工作的。
|
il y a 1 mois |
|
utils.py
|
fbebca0978
已经完成对定时订阅功能的公共函数的优化和测试
|
il y a 1 mois |
wangxq
935efc4d4b
pipeline_prepare 同时把plan写成json文件和数据库表