5930f1d5fd6d259db43e895ffccc4917344451d6,dataset/pipeline.py,Pipeline,_exec_all_actions,#Pipeline#Any#Any#,526

Before Change

                self._exec_import_model(batch, _action)
            elif _action["name"] == TRAIN_MODEL_ID:
                self._exec_train_model(batch, _action)
            elif _action["name"] == PREDICT_MODEL_ID:
                self._exec_predict_model(batch, _action)
            elif _action["name"] == PRINT_VARIABLE_ID:
                self._exec_print_variable(batch, _action)
            elif _action["name"] == UPDATE_VARIABLE_ID:
                self._exec_update_variable(batch, _action)
            elif _action["name"] == CALL_ID:
                self._exec_call(batch, _action)

After Change

        action_list = action_list or self._action_list
        for action in action_list:
            _action = action.copy()
            _action["kwargs"] = self._get_value(action["kwargs"], batch=batch)

            if _action.get("//dont_run", False):
                pass
            elif _action["name"] in [JOIN_ID, MERGE_ID]:

Instances