migrate change

Author: ChristopherHX

services/actions/task.go

@@ -22,6 +22,18 @@ func PickTask(ctx context.Context, runner *actions_model.ActionRunner) (*runnerv
 	)
 
 	if err := db.WithTx(ctx, func(ctx context.Context) error {
+		if runner.Ephemeral {
+			var task actions_model.ActionTask
+			has, err := db.GetEngine(ctx).Where("runner_id = ?", runner.ID).Get(&task)
+			if err == nil && has {
+				if task.Status == actions_model.StatusWaiting || task.Status == actions_model.StatusRunning || task.Status == actions_model.StatusBlocked {
+					return nil
+				}
+				// task has been finished, remove it
+				_, _ = db.GetEngine(ctx).Delete(runner)
+				return fmt.Errorf("runner has been removed")
+			}
+		}
 		t, ok, err := actions_model.CreateTaskForRunner(ctx, runner)
 		if err != nil {
 			return fmt.Errorf("CreateTaskForRunner: %w", err)