action_pipeline.py

class ActionPipeline:
    def __init__(self):
        self.registry = {}

    def register(self, action_name: str, handler):
        self.registry[action_name] = handler

    def execute(self, action_name: str, *args, **kwargs):
        if action_name in self.registry:
            try:
                result = self.registry[action_name](*args, **kwargs)
                return f"✅ Action '{action_name}' executed successfully: {result}"
            except Exception as e:
                return f"❌ Error during '{action_name}': {str(e)}"
        return f"⚠️ Unknown action: '{action_name}'"

    def list_actions(self):
        return list(self.registry.keys())