I am trying to write a function that reads the data in it using transform decorator and return the dataframe to the calling module. I tried the below approach and it isn’t working. Can someone let me know what I am doing wrong. I added the last three lines just to check def data_read(rid, output_file): @transform( output_fi=Output(output_file), src_input=Input('{rid}'.format(rid=rid)) ) def data_output(output_fi, src_input): df = src_input.dataframe() return df return data_output Continue reading...
