Closed Hades-888 closed 1 year ago
update sort by dag key in metasporeflow (#228)
example:
scheduler.yaml:
apiVersion: metaspore/v1 kind: OfflineCrontabScheduler metadata: name: offline_crontab_scheduler spec: cronExpr: "* */1 * * *" dag: join_data: [ "train_model_pop" ] sync_data: [ "join_data" ]
dag nodes before: ['join_data', 'train_model_pop', 'sync_data']
['join_data', 'train_model_pop', 'sync_data']
dag nodes after: ['sync_data', 'train_model_pop', 'join_data']
['sync_data', 'train_model_pop', 'join_data']
update sort by dag key in metasporeflow (#228)
example:
scheduler.yaml:
dag nodes before:
['join_data', 'train_model_pop', 'sync_data']
dag nodes after:
['sync_data', 'train_model_pop', 'join_data']