X-Git-Url: https://git.stderr.nl/gitweb?p=matthijs%2Fprojects%2Fbackupninja.git;a=blobdiff_plain;f=src%2Flib%2Fbackupninja%2Faction.py;h=b4245f4c236b6a2961ecc6dc8932dd96f4956712;hp=de36c4ba713fb7a5198d5abdc9d0792fdbfe6427;hb=d64d30066c2cbcf02e1c4d05198ca430584b5cbd;hpb=a2f36355bac67e7369ad224e2f4276a1768e4f50 diff --git a/src/lib/backupninja/action.py b/src/lib/backupninja/action.py index de36c4b..b4245f4 100644 --- a/src/lib/backupninja/action.py +++ b/src/lib/backupninja/action.py @@ -21,6 +21,7 @@ """ Running backup actions """ +import os import logging as log from backupninja import config @@ -35,39 +36,39 @@ def run_all_actions(opts, global_config): """ log.info('Running all actions') try: - actions = config.list_actions(opts) + action_configs = config.list_actions(opts) except OSError, e: log.critical('Unable to list actions: %s', e) return - actions.sort() + action_configs.sort() - for action in actions: - run_action(action, opts, global_config) + for action_config in action_configs: + run_action(action_config, opts, global_config) -def run_action(action, opts, global_config): +def run_action(action_config, opts, global_config): """ - Run a single action. opts are the parsed commandline options, + Run a single action. action_config is the full path to its + configuration file. opts are the parsed commandline options, global_config is the parsed global configuration. """ - log.info('Running action "%s"', action) # Split the action filename - parts = action.split('.') + parts = os.path.basename(action_config).split('.') if (len(parts) != 2): - log.error('Invalid action filename: "%s". Should be in the form name.type, where type is a valid handler.' % action) + log.error('Invalid action filename: "%s". Should be in the form name.type, where type is a valid handler.' % action_config) return (action_name, action_ty) = parts - - # Get the config for this action - action_config = config.get_action_config(opts, action) + log.info('Running action "%s.%s"', action_name, action_ty) try: # Create a handler for this action - handler = handlers.create_handler(action_ty, action_config) + handler = handlers.create_handler(action_ty) + # Let the handler load its configuration file + handler.load_config(action_config) # Run it handler.run(test=opts.test) handler.finish(test=opts.test) except Exception, e: - log.error('Running action "%s" failed: %s', action, e) + log.error('Running action "%s.%s" failed: %s', action_name, action_ty, e) import traceback log.debug(traceback.format_exc())