diff --git a/repo/actions/dataset.go b/repo/actions/dataset.go
index 4b13319bf..a981102d8 100644
--- a/repo/actions/dataset.go
+++ b/repo/actions/dataset.go
@@ -30,9 +30,9 @@ func (act Dataset) CreateDataset(name string, ds *dataset.Dataset, data cafs.Fil
 		return
 	}
 
-	if ds.Transform != nil && data == nil {
+	if ds.Transform != nil {
 		log.Info("running transformation...")
-		data, err = act.ExecTransform(ds)
+		data, err = act.ExecTransform(ds, data)
 		if err != nil {
 			return
 		}
diff --git a/repo/actions/transform.go b/repo/actions/transform.go
index daaf9359d..2f5ca1f03 100644
--- a/repo/actions/transform.go
+++ b/repo/actions/transform.go
@@ -12,9 +12,9 @@ import (
 )
 
 // ExecTransform executes a designated transformation
-func (act Dataset) ExecTransform(ds *dataset.Dataset) (file cafs.File, err error) {
+func (act Dataset) ExecTransform(ds *dataset.Dataset, infile cafs.File) (file cafs.File, err error) {
 	filepath := ds.Transform.ScriptPath
-	rr, err := skytf.ExecFile(ds, filepath)
+	rr, err := skytf.ExecFile(ds, filepath, infile)
 	if err != nil {
 		return nil, err
 	}