Fix/airflow settings update (#389)

* Check for airflow version to change command

* WIP Test case

* Update tests

* Add EOF line

* Default to Airflow 1 command without image tag

airflow/docker.go

@@ -685,7 +685,7 @@ func airflowVersionFromDockerFile(airflowHome string, dockerfile string) (uint64
 	semVer, err := semver.NewVersion(airflowTag)
 
 	if err != nil {
-		return 0, errors.Wrapf(err, "failed to parse dockerfile Airflow tag: %s", airflowTag)
+		return uint64(0x1), nil // Default to Airflow 1 if the user has a custom image without a semVer tag
 	}
 
 	return semVer.Major(), nil

airflow/docker_test.go

@@ -178,15 +178,18 @@ func Test_airflowVersionFromDockerFile(t *testing.T) {
 	assert.NoError(t, err)
 	assert.Equal(t, expected, version)
 
-	// Invalid Dockerfile
-	dockerfile = "Dockerfile.not.real"
+	// Default to Airflow 1 when there is an invalid Tag
+	expected = uint64(0x1)
+	dockerfile = "Dockerfile.tag.invalid"
 	version, err = airflowVersionFromDockerFile(airflowHome, dockerfile)
 
-	assert.Error(t, err)
+	assert.NoError(t, err)
+	assert.Equal(t, expected, version)
 
-	// Invalid Airflow Tag
-	dockerfile = "Dockerfile.tag.invalid"
+	// Invalid Dockerfile
+	dockerfile = "Dockerfile.not.real"
 	version, err = airflowVersionFromDockerFile(airflowHome, dockerfile)
 
 	assert.Error(t, err)
+
 }