Method run

tests/utils/plugin_test.py:43–46

(self, workflow_cls=Type[Workflow])

            assert workflow is not None, "Workflow 'my_workflow' not found in registry"

    def run(self, workflow_cls=Type[Workflow]):
        if self.monitor:
            self.monitor.log({"rollout": 2}, step=1, commit=True)
        return workflow_cls(task=None, model=None).run()


class TestPluginLoader(unittest.TestCase):