def process_levels()

in workflows-generator/ComposerDagGenerator.py [0:0]

• 11 lines of code
• 2 McCabe index (conditional complexity)

    def process_levels(self, config):
        """method to process levels"""
        levels = []
        for index, level in enumerate(config):
            threads = self.process_threads(level.get("THREADS"), level.get("LEVEL_ID"))
            level_body = self.level_template.replace("{LEVEL_ID}", level.get("LEVEL_ID"))
            level_body = level_body.replace("<<THREADS>>", "".join(threads))
            level_body = level_body.replace("<<THREAD_DEPENDENCIES>>",
                                            self.get_thread_dependency_string(level.get("THREADS"),
                                                                              level.get("LEVEL_ID")))
            levels.append(level_body)

        return levels