Skip to content

Add a dummy output_key param in PandasOperator to bypass pipeline compile error#494

Merged
SunnyHaze merged 1 commit intoOpenDCAI:mainfrom
fatty-belly:main
Mar 24, 2026
Merged

Add a dummy output_key param in PandasOperator to bypass pipeline compile error#494
SunnyHaze merged 1 commit intoOpenDCAI:mainfrom
fatty-belly:main

Conversation

@fatty-belly
Copy link
Copy Markdown
Contributor

Add a dummy output_key param in PandasOperator to bypass pipeline compile error in case new columns are introduced in PandasOperator.

示例:

foo_operator = PandasOperator(process_fn=[ foo ])

现在如果foo引入了新的key='bar',后面的算子又要用到这个key作为input,会在pipeline.compile时报错。

修改之后,只需要在算子运行时写成

self.foo_operator.run(storage = self.storage.step(), output_key="bar")

就不会再报错了。

…pile error in case new columns are introduced in PandasOperator
Copy link
Copy Markdown
Collaborator

@SunnyHaze SunnyHaze left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM, Thanks!

@SunnyHaze SunnyHaze merged commit d80daa9 into OpenDCAI:main Mar 24, 2026
9 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants