2 files changed, 5 insertions, 5 deletions
diff --git a/lib/task/isisBatchTask.class.php b/lib/task/isisBatchTask.class.php
index 95be44c..02cb526 100644
--- a/lib/task/isisBatchTask.class.php
+++ b/lib/task/isisBatchTask.class.php
@@ -27,7 +27,7 @@ EOF;
 
   protected function execute($arguments = array(), $options = array())
   {
-    // initialize the database connection
+    // Initialize the database connection.
     $databaseManager = new sfDatabaseManager($this->configuration);
     $connection      = $databaseManager->getDatabase($options['connection'])->getConnection();
 
@@ -46,15 +46,15 @@ EOF;
 
     foreach ($databases as $database)
     {
-      $rows = (isset($arguments['rows'])) ? $argument['rows'] : 20;
-      $max  = 1000; // TODO
+      $rows = (isset($arguments['rows'])) ? $argument['rows'] : 100;
+      $max  = $isis->info($this, 'task', $database);
 
       for ($offset = 0; $offset <= $max; $offset = $offset + $rows)
       {
         $pid = pcntl_fork();
         if ($pid == -1)
         {
-          die('Could not fork');
+          die('Could not fork.');
         }
         else if ($pid)
         {
diff --git a/lib/task/isisImportTask.class.php b/lib/task/isisImportTask.class.php
index 124932c..eb8b500 100644
--- a/lib/task/isisImportTask.class.php
+++ b/lib/task/isisImportTask.class.php
@@ -27,7 +27,7 @@ EOF;
 
   protected function execute($arguments = array(), $options = array())
   {
-    // initialize the database connection
+    // Initialize the database connection.
     $databaseManager = new sfDatabaseManager($this->configuration);
     $connection      = $databaseManager->getDatabase($options['connection'])->getConnection();