diff --git a/cmd/go_migrate/process.go b/cmd/go_migrate/process.go
index 1210f1c..5c48c87 100644
--- a/cmd/go_migrate/process.go
+++ b/cmd/go_migrate/process.go
@@ -112,7 +112,7 @@ func processMigrationJob(
 	}
 
 	chJobErrors := make(chan custom_errors.JobError, jobErrorsChannelSize)
-	chPartitions := make(chan models.Partition, job.ExtractorQueueSize)
+	chPartitions := make(chan models.Partition)
 	chBatchesRaw := make(chan models.Batch, job.ExtractorQueueSize)
 	chBatchesTransformed := make(chan models.Batch, job.TransformerQueueSize)
 
diff --git a/internal/app/custom_errors/loader.error.go b/internal/app/custom_errors/loader.error.go
deleted file mode 100644
index 1c12c2e..0000000
--- a/internal/app/custom_errors/loader.error.go
+++ /dev/null
@@ -1,14 +0,0 @@
-package custom_errors
-
-import (
-	"git.ksdemosapps.com/kylesoda/go-migrate/internal/app/models"
-)
-
-type LoaderError struct {
-	Batch models.Batch
-	Msg   string
-}
-
-func (e *LoaderError) Error() string {
-	return e.Msg
-}
diff --git a/internal/app/custom_errors/extractor.error.go b/internal/app/custom_errors/types.go
similarity index 69%
rename from internal/app/custom_errors/extractor.error.go
rename to internal/app/custom_errors/types.go
index 1ab5888..10b8cfb 100644
--- a/internal/app/custom_errors/extractor.error.go
+++ b/internal/app/custom_errors/types.go
@@ -14,3 +14,12 @@ type ExtractorError struct {
 func (e *ExtractorError) Error() string {
 	return e.Msg
 }
+
+type LoaderError struct {
+	Batch models.Batch
+	Msg   string
+}
+
+func (e *LoaderError) Error() string {
+	return e.Msg
+}
diff --git a/internal/app/etl/transformers/types.go b/internal/app/etl/transformers/types.go
deleted file mode 100644
index b3fa142..0000000
--- a/internal/app/etl/transformers/types.go
+++ /dev/null
@@ -1 +0,0 @@
-package transformers