def process_steps_vars()

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

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

    def process_steps_vars(self, config):
        """Method to process steps vars"""
        string_code = "{JOB_ID} = extract_job_params('{JOB_ID}','{FUNCTION_NAME}')\nfor key, value in {JOB_ID}.items():\n\tdefault_args['{JOB_ID}'+key] = value\n"
        vars = [
            string_code.format(
                JOB_ID=step.get("JOB_NAME"), FUNCTION_NAME=step.get("COMPOSER_STEP")
            )
            for level in config
            for thread in level.get("THREADS", [])
            for step in thread.get("STEPS", [])
        ]
        return '\n'.join(vars)