           $set:
             _schema: @Meta.schema
 
+    # Return if updateAll should be called
+    updateAll
+
   @updateAll: ->
     setupObservers true
 

      else
        newName = currentName

      future = new Future()
      migration.forward db, currentName, currentSchema, newSchema, future.resolver()
      migrated = future.wait()

      if i < migrationsPending
        count = globals.Document.Migrations.update

    initializing = false

  @_Migration: class
    updateAll: =>
      @_updateAll = true

    forward: (db, collectionName, currentSchema, newSchema, callback) =>
      db.collection collectionName, (error, collection) =>
        return callback error if error
