Ben Muller

    Ben Muller

    2 months ago
    Hey - I am registering a flow like with these arguments/parameters => 🧵
    au_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:
    It is registering fine, but I am not seeing any thing being scheduled, I am sure it is a typo or somethign but cant work it out
    The UI even shows it has a schedule, but it has no upcoming runs
    so it seems providing a
    None
    as a value breaks the scheduling mechanism ?
    Kevin Kho

    Kevin Kho

    2 months ago
    I think it can’t be scheduled if the parameter is required
    Ben Muller

    Ben Muller

    2 months ago
    It was both.