# values.yaml

dasgterDaemon:
  ...
  env:
    DAGSTER_GRPC_TIMEOUT_SECONDS: '180'

dagster._grpc.client

ge_influxdb_daily_schedule = build_schedule_from_multipartitioned_job(
    ge_influxdb_daily_job,
    hour_of_day=1,
    minute_of_hour=5,
    tags={
        "dagster/priority": "10",
    },
)

def build_schedule_from_multipartitioned_job(
    job: JobDefinition,
    description=None,
    name=None,
    minute_of_hour=None,
    hour_of_day=None,
    day_of_week=None,
    day_of_month=None,
    default_status=DefaultScheduleStatus.STOPPED,
    tags=None,
):
    multipartitions_def: MultiPartitionsDefinition = job.partitions_def
    time_window_partitions_def: TimeWindowPartitionsDefinition = (
        multipartitions_def.primary_dimension.partitions_def
    )
    static_partitions_def: StaticPartitionsDefinition = (
        multipartitions_def.secondary_dimension.partitions_def
    )

    cron_schedule = time_window_partitions_def.get_cron_schedule(
        minute_of_hour, hour_of_day, day_of_week, day_of_month
    )

    @schedule(
        cron_schedule=cron_schedule,
        job=job,
        default_status=default_status,
        execution_timezone=time_window_partitions_def.timezone,
        name=check.opt_str_param(name, "name", f"{job.name}_schedule"),
        tags=tags,
        description=check.opt_str_param(description, "description"),
    )
    def _schedule(context: ScheduleEvaluationContext):

        # Run for the latest partition.
        # Prior partitions will have been handled by prior ticks.
        time_key = time_window_partitions_def.get_last_partition_key(
            context.scheduled_execution_time
        )

        for static_key in static_partitions_def.get_partition_keys():
            multipartition_key = MultiPartitionKey(
                {
                    multipartitions_def.primary_dimension.name: time_key,
                    multipartitions_def.secondary_dimension.name: static_key,
                }
            )
            yield job.run_request_for_partition(
                partition_key=multipartition_key,
                run_key=multipartition_key,
                tags=tags,
            )

    return _schedule