I'm running it in this way :

SequentialRunner().run(pipeline=my_pipeline.from_nodes("node1").to_nodes("node10"),catalog=test)