Ben Muller
06/27/2022, 3:03 AMau_nz_greys_win_place = CronClock(
cron="15 * * * *",
parameter_defaults={
"race_types": None,
"market_type_codes": ["WIN", "PLACE"],
"event_type_ids": ["4339"],
"market_countries": ["AU", "NZ"],
"table_name": "greyhound_market_catalogue_au_nz",
},
start_date=datetime.now(tz=timezone("Australia/Brisbane")),
)
au_harness_win_place = CronClock(
cron="33 * * * *",
parameter_defaults={
"race_types": ["Harness"],
"market_type_codes": ["WIN", "PLACE"],
"event_type_ids": None,
"market_countries": ["AU"],
"table_name": "harness_market_catalogue_au",
},
start_date=datetime.now(tz=timezone("Australia/Brisbane")),
)
with Flow(
name="betfair_market_catalogues",
storage=Storage.in_a_s3_bucket(),
run_config=RunConfig().fargate_on_ecs(),
schedule=Schedule(clocks=[au_nz_greys_win_place, au_harness_win_place]),
executor=LocalDaskExecutor(scheduler="threads"),
) as flow:
None
as a value breaks the scheduling mechanism ?Kevin Kho
Ben Muller
06/27/2022, 8:12 AM