diff --git a/src/MigrateBatchExecutable.php b/src/MigrateBatchExecutable.php
index 21ab133..1065a4b 100644
--- a/src/MigrateBatchExecutable.php
+++ b/src/MigrateBatchExecutable.php
@@ -172,7 +172,7 @@ class MigrateBatchExecutable extends MigrateExecutable {
       }
 
       $operations[] = [
-        sprintf('%s::%s', self::class, 'batchProcessImport'),
+        sprintf('%s::%s', static::class, 'batchProcessImport'),
         [$migration->id(), $options],
       ];
     }
@@ -211,7 +211,7 @@ class MigrateBatchExecutable extends MigrateExecutable {
       $options['limit'] -= $context['results'][$migration->id()]['@numitems'];
     }
 
-    $executable = new MigrateBatchExecutable($migration, $message, $options);
+    $executable = new static($migration, $message, $options);
 
     if (empty($context['sandbox']['total'])) {
       $context['sandbox']['total'] = $executable->getSource()->count();