Add scheduled machines to fly.toml

internal/appconfig/config.go

@@ -51,6 +51,7 @@ type Config struct {
 
 	// Fields that are process group aware must come after Processes
 	Processes        map[string]string         `toml:"processes,omitempty" json:"processes,omitempty"`
+	Schedules        map[string]string         `toml:"schedules,omitempty" json:"schedules,omitempty"`
 	Mounts           []Mount                   `toml:"mounts,omitempty" json:"mounts,omitempty"`
 	HTTPService      *HTTPService              `toml:"http_service,omitempty" json:"http_service,omitempty"`
 	Services         []Service                 `toml:"services,omitempty" json:"services,omitempty"`

internal/appconfig/machines.go

@@ -347,6 +347,9 @@ func (c *Config) updateMachineConfig(src *fly.MachineConfig) (*fly.MachineConfig
 		mConfig.Guest = guest
 	}
 
+	// Schedule
+	mConfig.Schedule = c.Schedules[processGroup]
+
 	// Restart Policy
 	mConfig.Restart = nil
 

internal/appconfig/processgroups.go

@@ -113,6 +113,11 @@ func (c *Config) Flatten(groupName string) (*Config, error) {
 		return dst.flattenGroupMatches(groupName, k)
 	})
 
+	// [schedules]
+	dst.Schedules = lo.PickBy(dst.Schedules, func(k, v string) bool {
+		return k == groupName
+	})
+
 	// [checks]
 	dst.Checks = lo.PickBy(dst.Checks, func(_ string, check *ToplevelCheck) bool {
 		return matchesGroups(check.Processes)

internal/command/deploy/machines_deploymachinesapp.go

@@ -406,8 +406,8 @@ func suggestChangeWaitTimeout(err error, flagName string) error {
 
 func (md *machineDeployment) waitForMachine(ctx context.Context, e *machineUpdateEntry) error {
 	lm := e.leasableMachine
-	// Don't wait for SkipLaunch machines, they are updated but not started
-	if e.launchInput.SkipLaunch {
+	// Don't wait for SkipLaunch or scheduled machines, they are updated but not started
+	if e.launchInput.SkipLaunch || e.launchInput.Config.Schedule != "" {
 		return nil
 	}
 
@@ -839,8 +839,8 @@ func (md *machineDeployment) spawnMachineInGroup(ctx context.Context, groupName
 	statuslogger.Logf(ctx, "Machine %s was created", md.colorize.Bold(lm.FormattedMachineId()))
 	defer lm.ReleaseLease(ctx)
 
-	// Don't wait for SkipLaunch machines, they are created but not started
-	if launchInput.SkipLaunch {
+	// Don't wait for SkipLaunch or scheduled machines, they are created but not started
+	if launchInput.SkipLaunch || launchInput.Config.Schedule != "" {
 		return lm, nil
 	}