add --image flag for image only deploy (#1446)

* add --image flag for image only deploy

* don't send tarball on image only

* image only deploy works

* image only deploy works

* fix lint

* add errors

Author: sunkickr

cloud/deploy/deploy.go

@@ -105,6 +105,7 @@ type InputDeploy struct {
 	DeploymentName string
 	Prompt         bool
 	Dags           bool
+	Image          bool
 	WaitForStatus  bool
 	DagsPath       string
 	Description    string
@@ -235,7 +236,6 @@ func Deploy(deployInput InputDeploy, client astro.Client, coreClient astrocore.C
 	if err != nil {
 		return err
 	}
-
 	resp, err := createDeploy(deployInfo.organizationID, deployInfo.deploymentID, deployInput.Description, "", deployInput.Dags, coreClient)
 	if err != nil {
 		return err
@@ -326,7 +326,7 @@ func Deploy(deployInput InputDeploy, client astro.Client, coreClient astrocore.C
 			return fmt.Errorf("%w %s", envFileMissing, deployInput.EnvFile)
 		}
 
-		if deployInfo.dagDeployEnabled && len(dagFiles) == 0 && config.CFG.ShowWarnings.GetBool() {
+		if deployInfo.dagDeployEnabled && len(dagFiles) == 0 && config.CFG.ShowWarnings.GetBool() && !deployInput.Image {
 			i, _ := input.Confirm("Warning: No DAGs found. This will delete any existing DAGs. Are you sure you want to deploy?")
 
 			if !i {
@@ -366,12 +366,30 @@ func Deploy(deployInput InputDeploy, client astro.Client, coreClient astrocore.C
 		}
 
 		if deployInfo.dagDeployEnabled && len(dagFiles) > 0 {
-			dagTarballVersion, err = deployDags(deployInput.Path, dagsPath, deployInfo.deploymentType, dagsUploadURL)
+			if !deployInput.Image {
+				dagTarballVersion, err = deployDags(deployInput.Path, dagsPath, deployInfo.deploymentType, dagsUploadURL)
+				if err != nil {
+					return err
+				}
+			} else {
+				if !deployInfo.dagDeployEnabled {
+					return fmt.Errorf(enableDagDeployMsg, deployInfo.deploymentID) //nolint
+				}
+				fmt.Println("Image Deploy only. Skipping deploying DAG...")
+			}
+		}
+		// finish deploy
+		if deployInput.Image {
+			coreDeployment, err := deployment.CoreGetDeployment(deployInfo.workspaceID, deployInfo.organizationID, deployInfo.deploymentID, coreClient)
 			if err != nil {
 				return err
 			}
+			if coreDeployment.CurrentDagTarballVersion != nil {
+				dagTarballVersion = *coreDeployment.CurrentDagTarballVersion
+			} else {
+				dagTarballVersion = ""
+			}
 		}
-		// finish deploy
 		err = updateDeploy(deployID, deployInfo.deploymentID, deployInfo.organizationID, dagTarballVersion, deployInfo.dagDeployEnabled, coreClient)
 		if err != nil {
 			return err
@@ -412,7 +430,6 @@ func getDeploymentInfo(deploymentID, wsID, deploymentName string, prompt bool, c
 		if err != nil {
 			return deploymentInfo{}, err
 		}
-
 		return deploymentInfo{
 			currentDeployment.ID,
 			currentDeployment.ReleaseName,

cmd/cloud/deploy.go

@@ -20,6 +20,7 @@ var (
 	parse             bool
 	dags              bool
 	waitForDeploy     bool
+	image             bool
 	dagsPath          string
 	pytestFile        string
 	envFile           string
@@ -63,6 +64,7 @@ func NewDeployCmd() *cobra.Command {
 	cmd.Flags().StringVarP(&pytestFile, "test", "t", "", "Location of Pytests or specific Pytest file. All Pytest files must be located in the tests directory")
 	cmd.Flags().StringVarP(&imageName, "image-name", "i", "", "Name of a custom image to deploy")
 	cmd.Flags().BoolVarP(&dags, "dags", "d", false, "Push only DAGs to your Astro Deployment")
+	cmd.Flags().BoolVarP(&image, "image", "", false, "Push only an image to your Astro Deployment. If you have DAG Deploy enabled your DAGs will not be affected.")
 	cmd.Flags().StringVar(&dagsPath, "dags-path", "", "If set deploy dags from this path instead of the dags from working directory")
 	cmd.Flags().StringVarP(&deploymentName, "deployment-name", "n", "", "Name of the deployment to deploy to")
 	cmd.Flags().BoolVar(&parse, "parse", false, "Succeed only if all DAGs in your Astro project parse without errors")
@@ -104,6 +106,10 @@ func deploy(cmd *cobra.Command, args []string) error {
 		}
 	}
 
+	if dags && image {
+		return errors.New("cannot use both --dags and --image together. Run 'astro deploy' to update both your image and dags")
+	}
+
 	// Save deploymentId in config if specified
 	if len(deploymentID) > 0 && saveDeployConfig {
 		err := config.CFG.ProjectDeployment.SetProjectString(deploymentID)
@@ -137,6 +143,7 @@ func deploy(cmd *cobra.Command, args []string) error {
 		DeploymentName: deploymentName,
 		Prompt:         forcePrompt,
 		Dags:           dags,
+		Image:          image,
 		WaitForStatus:  waitForDeploy,
 		DagsPath:       dagsPath,
 		Description:    deployDescription,