'Gets the type signature of the dependency output.'

def _get_type_signature_for_dependency(self, dependency):

    if isinstance(dependency, (pipeline.Pipeline, pipeline.PipelineKey, DagInput)):
        return dependency.output_type
    return dict([(name, sub_dep.output_type) for (name, sub_dep) in dependency.items()])
