Validate access to cortex bucket on deploy (#511)

Author: deliahu

pkg/operator/context/deployment_version.go

@@ -22,7 +22,6 @@ import (
 
 	"github.com/cortexlabs/cortex/pkg/consts"
 	"github.com/cortexlabs/cortex/pkg/lib/aws"
-	"github.com/cortexlabs/cortex/pkg/lib/errors"
 	libtime "github.com/cortexlabs/cortex/pkg/lib/time"
 	"github.com/cortexlabs/cortex/pkg/operator/config"
 )
@@ -38,20 +37,29 @@ func getOrSetDeploymentVersion(appName string, ignoreCache bool) (string, error)
 		deploymentVersion := libtime.Timestamp(time.Now())
 		err := config.AWS.UploadStringToS3(deploymentVersion, deploymentVersionFileKey)
 		if err != nil {
-			return "", errors.Wrap(err, "deployment version") // unexpected error
+			if aws.IsNoSuchBucketErr(err) {
+				return "", aws.ErrorBucketInaccessible(config.AWS.Bucket)
+			}
+			return "", err
 		}
 		return deploymentVersion, nil
 	}
 
 	deploymentVersion, err := config.AWS.ReadStringFromS3(deploymentVersionFileKey)
 	if err != nil {
 		if !aws.IsNoSuchKeyErr(err) {
-			return "", errors.Wrap(err, "deployment version") // unexpected error
+			if aws.IsNoSuchBucketErr(err) {
+				return "", aws.ErrorBucketInaccessible(config.AWS.Bucket)
+			}
+			return "", err
 		}
 		deploymentVersion = libtime.Timestamp(time.Now())
 		err := config.AWS.UploadStringToS3(deploymentVersion, deploymentVersionFileKey)
 		if err != nil {
-			return "", errors.Wrap(err, "deployment version") // unexpected error
+			if aws.IsNoSuchBucketErr(err) {
+				return "", aws.ErrorBucketInaccessible(config.AWS.Bucket)
+			}
+			return "", err
 		}
 	}
 	return deploymentVersion, nil