Is it possible to send PandaSerializer results to a flow triggered by StartFlowRun?
k
Kevin Kho
09/10/2021, 8:58 PM
Hey @Henry, the serializer is specified at a task level or at the flow when you register. I think it would need to be registered with the subflow and it can’t dynamically be changed by StartFlowRun if that is what you are asking
h
Henry
09/10/2021, 8:59 PM
hmmm, how would i setup the parameters so that it could receive a dataframe?
k
Kevin Kho
09/10/2021, 9:02 PM
I don’t believe you can because Parameters need to be JSONSerializeable as they are passed through the API and pd.DataFrame can’t be passed. You either need to pass a location for it to be loaded in the flow, or you need to pass something like a Dict[List] maybe and construct it? Not sure if that would work.
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.