Internal access to the source step. Should not be used outside
        of Cauldron development.

        :return:
            The ProjectStep instance that this ExposedStep represents
497703
def _step(self) -> typing.Union[None, 'projects.ProjectStep']:
        
        import cauldron
        try:
            return cauldron.project.get_internal_project().current_step
        except Exception:
            return None
502517
def _get_step_inout(step):
    
    inputs = []
    outputs = []
    assert step.inputs_record_schema["type"] == "record"
    for inp in step.inputs_record_schema["fields"]:
        source = inp["source"].split("#")[-1].replace("/", ".")
        # Check if we're unpacking from a record, and unpack from our object
        if "valueFrom" in inp:
            attr_access = "['%s']" % inp["name"]
            if inp["valueFrom"].find(attr_access) > 0:
                source += ".%s" % inp["name"]
        inputs.append({"id": inp["name"], "value": source})
    assert step.outputs_record_schema["type"] == "record"
    for outp in step.outputs_record_schema["fields"]:
        outputs.append({"id": outp["name"]})
    return inputs, outputs
1309364
def get_workflow(self):
        """"""
        extra_context = self.get_initial()
        entry_point = self.request.GET.get("step", None)
        workflow = self.workflow_class(self.request,
                                       context_seed=extra_context,
                                       entry_point=entry_point)
        return workflow
931680
def get_next_step(self):
        
        if self.selected_purpose() == layer_purpose_aggregation:
            new_step = self.parent.step_kw_field
        else:
            new_step = self.parent.step_kw_subcategory
        return new_step
835368
function(oStep){
		var bIsTopLevel = oStep.getParent() instanceof sap.ui.commons.RoadMap;
		var aSteps = oStep.getParent()[bIsTopLevel ? "getSteps" : "getSubSteps"]();
		var iCount = aSteps.length;
		for (var i = 0; i < aSteps.length; i++) {
			if (!aSteps[i].getVisible()) {
				iCount--;
			}
		}
		return iCount;
	}
161707
def _extract_from_subworkflow(vs, step):
    
    substep_ids = set([x.name for x in step.workflow])
    out = []
    for var in vs:
        internal = False
        parts = var["id"].split("/")
        if len(parts) > 1:
            if parts[0] in substep_ids:
                internal = True
        if not internal:
            var.pop("source", None)
            out.append(var)
    return out
1270586
def get_next_step(self):
        
        if self.parent.get_layer_geometry_key() == \
                layer_geometry_raster['key']:
            return self.parent.step_kw_source

        layer_purpose = self.parent.step_kw_purpose.selected_purpose()
        if layer_purpose['key'] != layer_purpose_aggregation['key']:
            subcategory = self.parent.step_kw_subcategory. \
                selected_subcategory()
        else:
            subcategory = {'key': None}

        # Check if it can go to inasafe field step
        non_compulsory_fields = get_non_compulsory_fields(
            layer_purpose['key'], subcategory['key'])
        if not skip_inasafe_field(self.parent.layer, non_compulsory_fields):
            return self.parent.step_kw_inasafe_fields

        # Check if it can go to inasafe default field step
        default_inasafe_fields = get_fields(
            layer_purpose['key'],
            subcategory['key'],
            replace_null=True,
            in_group=False
        )
        if default_inasafe_fields:
            return self.parent.step_kw_default_inasafe_fields

        # Any other case
        return self.parent.step_kw_source
1032138
private List<Object> getSourceFieldValues(TransformationStep step) throws Exception {
        List<Object> sources = new ArrayList<Object>();
        for (String sourceField : step.getSourceFields()) {
            Object object = getObjectValue(sourceField, true);
            if (object == null) {
                String message = String.format("The source field %s is null. Step will be be ignored", sourceField);
                throw new TransformationStepException(message);
            }
            sources.add(object);
        }
        return sources;
    }
18886
def get(self, sid):
        
        return ExecutionStepContext(
            self._version,
            flow_sid=self._solution['flow_sid'],
            execution_sid=self._solution['execution_sid'],
            sid=sid,
        )
636420
def global_step(device=''):
  
  global_step_ref = tf.get_collection(tf.GraphKeys.GLOBAL_STEP)
  if global_step_ref:
    return global_step_ref[0]
  else:
    collections = [
        VARIABLES_TO_RESTORE,
        tf.GraphKeys.GLOBAL_VARIABLES,
        tf.GraphKeys.GLOBAL_STEP,
    ]
    # Get the device for the variable.
    with tf.device(variable_device(device, 'global_step')):
      return tf.get_variable('global_step', shape=[], dtype=tf.int64,
                             initializer=tf.zeros_initializer(),
                             trainable=False, collections=collections)
1285663
protected void updateStep(int stepNo) {

        if ((0 <= stepNo) && (stepNo < m_steps.size())) {
            Class<? extends A_CmsSetupStep> cls = m_steps.get(stepNo);
            A_CmsSetupStep step;
            try {
                step = cls.getConstructor(I_SetupUiContext.class).newInstance(this);
                showStep(step);
                m_stepNo = stepNo; // Only update step number if no exceptions
            } catch (Exception e) {
                CmsSetupErrorDialog.showErrorDialog(e);
            }

        }
    }
167680
public Step<Flow<T>> getOrCreateStep()
   {
      List<Node> nodeList = childNode.get("step");
      if (nodeList != null &&  nodeList.size() > 0)
      {
         return new StepImpl<Flow<T>>(this, "step", childNode, nodeList.get(0));
      }
      return createStep();
   }
391268
function previousStep()
    {
        $this->setMetaData( 'current_stage', eZWizardBase::STAGE_PRE );
        $this->setMetaData( 'current_step', $this->metaData( 'current_step' ) - 1 );
        $this->savePersistentData();

        return $this->Module->redirectTo( $this->WizardURL );
    }
1100442
def _model_source_dir(self):
        
        return self.source_dir if self.sagemaker_session.local_mode else self.uploaded_code.s3_prefix
911182
function nextStep()
    {
        if ( $this->metaData( 'current_stage' ) == eZWizardBase::STAGE_PRE )
        {
            $this->setMetaData( 'current_stage', eZWizardBase::STAGE_POST );
        }
        else
        {
            $this->setMetaData( 'current_stage', eZWizardBase::STAGE_PRE );
            $this->setMetaData( 'current_step', $this->metaData( 'current_step' ) + 1 );

            return $this->Module->redirectTo( $this->WizardURL );
        }

        $this->savePersistentData();
    }
322834
def step_context(self):
        
        if self._step_context is None:
            self._step_context = StepContextList(
                self._version,
                flow_sid=self._solution['flow_sid'],
                engagement_sid=self._solution['engagement_sid'],
                step_sid=self._solution['sid'],
            )
        return self._step_context
1078377
public java.util.List<RemediationExecutionStep> getStepDetails() {
        if (stepDetails == null) {
            stepDetails = new com.amazonaws.internal.SdkInternalList<RemediationExecutionStep>();
        }
        return stepDetails;
    }