如何拆分Python链？

Question

有人使用 python-chain 包并且知道是否可以拆分链？我想像

intermediate_result = chain.state() >> step_1 >> step_2

final_result_1 = intermediate_result >> step_3_1 >> step_4_1
final_result_2 = intermediate_result >> step_3_2 >> step_4_2

这里是我的意思的包的链接： https://pypi.org/project /python-链/

Answer 1

找到 anwser：

intermediate_result = chain.state() >> step_1 >> step_2

final_result_1 = intermediate_result.current >> step_3_1 >> step_4_1
final_result_2 = intermediate_result.current >> step_3_2 >> step_4_2

请注意，只有在 middle_result 不包含任何不可序列化对象（例如 pyspark 数据帧）时，这才有效