def downstream(self, step_name):
        """Returns the direct dependencies of the given step"""
        return list(self.steps[dep] for dep in self.dag.downstream(step_name))
def downstream ( self , step_name ) : return list ( self . steps [ dep ] for dep in self . dag . downstream ( step_name ) )
Returns the direct dependencies of the given step