Pretty snazzy! But in general I wonder if there is a use case for having the data passed back into pandas, if its just going to be serialized again by an IO manager?
I think you could think about having the upstream asset write to the flight server and then the intermediate asset just calls the R function to process that data
And then you can connect the two with
non_argument_deps