如何拆分 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 数据帧)时有效
有人使用 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 数据帧)时有效