@@ -1259,7 +1259,7 @@ def load_migrated
1259
1259
def run_without_lock
1260
1260
migration = migrations . detect { |m | m . version == @target_version }
1261
1261
raise UnknownMigrationVersionError . new ( @target_version ) if migration . nil?
1262
- result = execute_migration_in_transaction ( migration , @direction )
1262
+ result = execute_migration_in_transaction ( migration )
1263
1263
1264
1264
record_environment
1265
1265
result
@@ -1271,10 +1271,7 @@ def migrate_without_lock
1271
1271
raise UnknownMigrationVersionError . new ( @target_version )
1272
1272
end
1273
1273
1274
- result = runnable . each do |migration |
1275
- execute_migration_in_transaction ( migration , @direction )
1276
- end
1277
-
1274
+ result = runnable . each ( &method ( :execute_migration_in_transaction ) )
1278
1275
record_environment
1279
1276
result
1280
1277
end
@@ -1294,14 +1291,14 @@ def invalid_target?
1294
1291
@target_version && @target_version != 0 && !target
1295
1292
end
1296
1293
1297
- def execute_migration_in_transaction ( migration , direction )
1294
+ def execute_migration_in_transaction ( migration )
1298
1295
return if down? && !migrated . include? ( migration . version . to_i )
1299
1296
return if up? && migrated . include? ( migration . version . to_i )
1300
1297
1301
1298
Base . logger . info "Migrating to #{ migration . name } (#{ migration . version } )" if Base . logger
1302
1299
1303
1300
ddl_transaction ( migration ) do
1304
- migration . migrate ( direction )
1301
+ migration . migrate ( @ direction)
1305
1302
record_version_state_after_migrating ( migration . version )
1306
1303
end
1307
1304
rescue => e
0 commit comments