def process_steps()

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

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

    def process_steps(self, steps, level_id, thread_id):
        """method to process steps"""
        step_bodies = []

        for index, step in enumerate(steps):
            step_body = self.process_step_async(level_id, thread_id, step)
            step_body = step_body.replace("{LEVEL_ID}", level_id)
            step_body = step_body.replace("{THREAD_ID}", thread_id)
            step_bodies.append(step_body)
        return step_bodies