Zhibin Dai
06/01/2022, 4:13 PMif flow.name == 'ppi_parent_flow':
clocks = []
for prop_source, prop_source_config in US_PROPERTIES_CONFIG_MAP.items():
clock = CronClock(cron=prop_source_config['schedule'], parameter_defaults={
PREFECT_DATASET_PARAM_NAME: prop_source, PREFECT_RUN_ENVIRONMENT_PARAM_NAME: run_env})
clocks.append(clock)
schedule = Schedule(clocks=clocks)
flow.schedule = schedule
US_PROPERTIES_CONFIG_MAP = {
'DATASET': {
'schedule': '0 5 * * 1-5'
}
}
Kevin Kho
06/01/2022, 4:35 PMZhibin Dai
06/01/2022, 4:37 PMKevin Kho
06/01/2022, 4:40 PMZhibin Dai
06/02/2022, 1:33 PMKevin Kho
06/02/2022, 2:33 PM