|
|
@ -285,7 +285,7 @@ var runAll = function (env, cb) {
|
|
|
|
});
|
|
|
|
});
|
|
|
|
};
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
var migrate function (env, cb) {
|
|
|
|
var migrate = function (env, cb) {
|
|
|
|
// list every task
|
|
|
|
// list every task
|
|
|
|
list(env, function (err, paths) {
|
|
|
|
list(env, function (err, paths) {
|
|
|
|
if (err) {
|
|
|
|
if (err) {
|
|
|
@ -307,6 +307,7 @@ var migrate function (env, cb) {
|
|
|
|
});
|
|
|
|
});
|
|
|
|
return;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
task = _task;
|
|
|
|
}));
|
|
|
|
}));
|
|
|
|
}).nThen(function (w) {
|
|
|
|
}).nThen(function (w) {
|
|
|
|
if (bypass) { return; }
|
|
|
|
if (bypass) { return; }
|
|
|
@ -323,17 +324,17 @@ var migrate function (env, cb) {
|
|
|
|
}).nThen(function (w) {
|
|
|
|
}).nThen(function (w) {
|
|
|
|
if (bypass) { return; }
|
|
|
|
if (bypass) { return; }
|
|
|
|
// remove
|
|
|
|
// remove
|
|
|
|
remove(env, path, function (err) {
|
|
|
|
remove(env, path, w(function (err) {
|
|
|
|
if (err) {
|
|
|
|
if (err) {
|
|
|
|
env.log.error("TASK_MIGRATION_REMOVE", {
|
|
|
|
env.log.error("TASK_MIGRATION_REMOVE", {
|
|
|
|
error: err,
|
|
|
|
error: err,
|
|
|
|
path: path,
|
|
|
|
path: path,
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
}
|
|
|
|
});
|
|
|
|
}));
|
|
|
|
});
|
|
|
|
});
|
|
|
|
});
|
|
|
|
});
|
|
|
|
nt = nt.nThen(function (w) {
|
|
|
|
nt = nt.nThen(function () {
|
|
|
|
cb();
|
|
|
|
cb();
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}, true);
|
|
|
|
}, true);
|
|
|
|