(self, subordinate)
Verifies that subordinate is DagInput, PipelineKey, or Pipeline.
Verifies that subordinate is DagInput, PipelineKey, or Pipeline.
Verifies that subordinate is DagInput PipelineKey or Pipeline .
def _validate_subordinate(self, subordinate):
    """Verifies that subordinate is DagInput, PipelineKey, or Pipeline."""
    if isinstance(subordinate, pipeline.Pipeline):
      return subordinate
    if isinstance(subordinate, pipeline.PipelineKey):
      if not isinstance(subordinate.unit, pipeline.Pipeline):
        raise InvalidDAGError(
            'PipelineKey object %s does not have a valid Pipeline'
            % subordinate)
      return subordinate.unit
    if isinstance(subordinate, DagInput):
      return subordinate
    raise InvalidDAGError(
        'Looking for Pipeline, PipelineKey, or DagInput object, but got %s'
        % type(subordinate))
def _validate_subordinate ( self , subordinate ) : if isinstance ( subordinate , pipeline . Pipeline ) : return subordinate if isinstance ( subordinate , pipeline . PipelineKey ) : if not isinstance ( subordinate . unit , pipeline . Pipeline ) : raise InvalidDAGError ( 'PipelineKey object %s does not have a valid Pipeline' % subordinate ) return subordinate . unit if isinstance ( subordinate , DagInput ) : return subordinate raise InvalidDAGError ( 'Looking for Pipeline, PipelineKey, or DagInput object, but got %s' % type ( subordinate ) )