Software / code / prosody
Changeset
12166:39483b4099b4
migrator: Add option to keep going despite errors
| author | Kim Alvefur <zash@zash.se> |
|---|---|
| date | Sun, 09 Jan 2022 16:08:15 +0100 |
| parents | 12165:79a51a48bdaf |
| children | 12167:03f551510b1e |
| files | tools/migration/prosody-migrator.lua |
| diffstat | 1 files changed, 14 insertions(+), 0 deletions(-) [+] |
line wrap: on
line diff
--- a/tools/migration/prosody-migrator.lua Sun Jan 09 15:52:50 2022 +0100 +++ b/tools/migration/prosody-migrator.lua Sun Jan 09 16:08:15 2022 +0100 @@ -37,6 +37,7 @@ local function usage() print("Usage: " .. arg[0] .. " [OPTIONS] FROM_STORE TO_STORE"); print(" --config FILE Specify config file") + print(" --keep-going Keep going in case of errors"); print(" -v, --verbose Incease log-level"); print(""); print("If no stores are specified, 'input' and 'output' are used."); @@ -183,6 +184,19 @@ end; } +if options["keep-going"] then + local xpcall = require "util.xpcall".xpcall; + local function log_err(err) + log("error", "Error migrating data: %s", err); + log("debug", "%s", debug.traceback()); + end + for t, f in pairs(migrate_once) do + migrate_once[t] = function (origin, destination, user) + xpcall(f, log_err, origin, destination, user); + end + end +end + local migration_runner = async.runner(function (job) for host, stores in pairs(job.input.hosts) do prosody.hosts[host] = startup.make_host(host);
