fix downPipe bug

This commit is contained in:
mattes 2014-08-12 03:30:44 +02:00
parent 7852745c6b
commit 707c9b9c07

View File

@ -106,8 +106,9 @@ func DownPipe(url, migrationsPath string, pipe chan interface{}) chan interface{
sendErrorAndClosePipe(err, pipe)
return pipe
}
if len(applyMigrationFiles) > 0 {
go d.Migrate(applyMigrationFiles, nil)
go d.Migrate(applyMigrationFiles, pipe)
return pipe
} else {
sendErrorAndClosePipe(errors.New("No migration files to apply."), pipe)