def process_step_sync()

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

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

    def process_step_sync(self,cloud_function_level_1_id, step, cloud_function_name):
        """method to process sync step"""
        #step_name = step.get("JOB_ID") + "_" + step.get("JOB_NAME")
        step_name = step.get("JOB_NAME")
        step_body = self.cloud_function_sync_template.replace("{JOB_ID}", step_name)
        step_body = step_body.replace("{CLOUD_FUNCITON_ID}", cloud_function_level_1_id)
        step_body = step_body.replace("{CLOUD_FUNCTION_TO_INVOKE}", cloud_function_name)
        step_body = step_body.replace("{ENVIRONMENT}", self.environment)
        step_body = step_body.replace("{JOB_IDENTIFIER}", step.get("JOB_ID"))
        step_body = step_body.replace("{JOB_NAME}", step.get("JOB_NAME"))
        if "TIMEOUT_SECONDS" in step.keys():
            step_body = step_body.replace("{TIMEOUT_SECONDS_BLOCK}",
                                          '"TimeoutSeconds": ' + step.get("TIMEOUT_SECONDS") + ',')
        else:
            step_body = step_body.replace("{TIMEOUT_SECONDS_BLOCK}", '')

        #TODO continue if fail logic
        if "CONTINUE_IF_FAIL" in step.keys():
            step_body = step_body.replace("{CONTINUE_IF_FAIL_BLOCK}", ',"PcontinueIfFail": "True"')
        else:
            step_body = step_body.replace("{CONTINUE_IF_FAIL_BLOCK}", '')

        return step_body