update extractor interface

2026-04-16 23:49:23 -05:00
parent 39c0d99502
commit 1c3db39b21
4 changed files with 78 additions and 22 deletions
--- a/cmd/go_migrate/process.go
+++ b/cmd/go_migrate/process.go
@@ -129,7 +129,7 @@ func processMigrationJob(

 	for range maxExtractors {
 		wgExtractors.Go(func() {
-			extractor.Exec(
+			extractor.Consume(
 				localCtx,
 				job.SourceTable,
 				sourceColTypes,