如何拆分 Python 链?

How to split up Python chain?

有人使用 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

这里的 link 我的意思是:https://pypi.org/project/python-chain/

找到答案:

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

请注意,这仅在 intermediate_result 不包含任何 non-serializable 对象(例如 pyspark 数据帧)时有效