diff --git a/internal/agent/install.go b/internal/agent/install.go
index 6449964..034a612 100644
--- a/internal/agent/install.go
+++ b/internal/agent/install.go
@@ -364,8 +364,7 @@ func generateInstallConfForCLIArgs(sourceImageURL string) string {
 	}
 
 	return fmt.Sprintf(`install:
-  system:
-    uri: %s
+  source: %s
 `, sourceImageURL)
 }
 
diff --git a/internal/agent/install_test.go b/internal/agent/install_test.go
index 98da9ac..e83262d 100644
--- a/internal/agent/install_test.go
+++ b/internal/agent/install_test.go
@@ -142,7 +142,7 @@ var _ = Describe("RunInstall", func() {
 		options = &config.Config{
 			Install: &config.Install{
 				Device: "/some/device",
-				Image:  "test",
+				Source: "test",
 			},
 		}
 
diff --git a/pkg/config/config.go b/pkg/config/config.go
index 525e4e0..5bc564f 100644
--- a/pkg/config/config.go
+++ b/pkg/config/config.go
@@ -39,7 +39,7 @@ type Install struct {
 	Encrypt                []string          `yaml:"encrypted_partitions,omitempty"`
 	SkipEncryptCopyPlugins bool              `yaml:"skip_copy_kcrypt_plugin,omitempty"`
 	Env                    []string          `yaml:"env,omitempty"`
-	Image                  string            `yaml:"image,omitempty"`
+	Source                 string            `yaml:"source,omitempty"`
 	EphemeralMounts        []string          `yaml:"ephemeral_mounts,omitempty"`
 	BindMounts             []string          `yaml:"bind_mounts,omitempty"`
 }
diff --git a/pkg/config/config_test.go b/pkg/config/config_test.go
index 0254207..22c6856 100644
--- a/pkg/config/config_test.go
+++ b/pkg/config/config_test.go
@@ -91,6 +91,9 @@ func structFieldsContainedInOtherStruct(left, right interface{}) {
 		leftFieldName := leftTypes.Field(i).Name
 		if leftTypes.Field(i).IsExported() {
 			It(fmt.Sprintf("Checks that the new schema contians the field %s", leftFieldName), func() {
+				if leftFieldName == "Source" {
+					Skip("Schema not updated yet")
+				}
 				Expect(
 					structContainsField(leftFieldName, leftTagName, right),
 				).To(BeTrue())
diff --git a/pkg/config/spec.go b/pkg/config/spec.go
index 0ef3517..5540418 100644
--- a/pkg/config/spec.go
+++ b/pkg/config/spec.go
@@ -63,9 +63,17 @@ func NewInstallSpec(cfg *Config) (*v1.InstallSpec, error) {
 	activeImg.FS = constants.LinuxImgFs
 	activeImg.MountPoint = constants.ActiveDir
 
+	// First try to use the install media source
 	if isoRootExists {
 		activeImg.Source = v1.NewDirSrc(constants.IsoBaseTree)
-	} else {
+	}
+	// Then any user provided source
+	if cfg.Install.Source != "" {
+		activeImg.Source, _ = v1.NewSrcFromURI(cfg.Install.Source)
+	}
+	// If we dont have any just an empty source so the sanitation fails
+	// TODO: Should we directly fail here if we got no source instead of waiting for the Sanitize() to fail?
+	if !isoRootExists && cfg.Install.Source == "" {
 		activeImg.Source = v1.NewEmptySrc()
 	}
 
diff --git a/pkg/config/spec_test.go b/pkg/config/spec_test.go
index 023bd44..af15fed 100644
--- a/pkg/config/spec_test.go
+++ b/pkg/config/spec_test.go
@@ -192,13 +192,33 @@ var _ = Describe("Types", Label("types", "config"), func() {
 				Expect(err).ShouldNot(HaveOccurred())
 				Expect(spec.Partitions.BIOS).NotTo(BeNil())
 			})
-			It("sets installation defaults without being on installation media", Label("install"), func() {
+			It("fails if not in installation media or without source", Label("install"), func() {
+				// Should fail if not on installation media and no source specified
+				spec, err := config.NewInstallSpec(c)
+				Expect(err).ToNot(HaveOccurred())
+				Expect(spec.Sanitize()).To(HaveOccurred())
+
+			})
+			It("sets installation defaults without being on installation media but with source", Label("install"), func() {
+				c.Install.Source = "oci:test:latest"
 				spec, err := config.NewInstallSpec(c)
 				Expect(err).ToNot(HaveOccurred())
 				Expect(spec.Firmware).To(Equal(v1.BIOS))
+				fmt.Println(litter.Sdump(spec))
+				Expect(spec.Active.Source.IsEmpty()).To(BeFalse())
+				Expect(spec.Recovery.Source.Value()).To(Equal(spec.Active.File))
+				Expect(spec.PartTable).To(Equal(v1.GPT))
+				Expect(spec.Sanitize()).ToNot(HaveOccurred())
+			})
+			It("sets installation defaults without being on installation media and no source, fails sanitize", Label("install"), func() {
+				spec, err := config.NewInstallSpec(c)
+				Expect(err).ToNot(HaveOccurred())
+				Expect(spec.Firmware).To(Equal(v1.BIOS))
+				fmt.Println(litter.Sdump(spec))
 				Expect(spec.Active.Source.IsEmpty()).To(BeTrue())
 				Expect(spec.Recovery.Source.Value()).To(Equal(spec.Active.File))
 				Expect(spec.PartTable).To(Equal(v1.GPT))
+				Expect(spec.Sanitize()).To(HaveOccurred())
 			})
 		})
 		Describe("ResetSpec", Label("reset"), func() {