Finishing our SG API Pipeline with Chronocoding - How I Write Pipes Part V

[@SaitopLam]

Could you give a hint on how to handle partitionedDataset in avg_temp_by_hour ?

[@DataEngineerOne]

Try wrapping the avg_temp_by_hour function with a function that will "unpack" the PartitionedDataSet, and call avg_temp_by_hour for each of the dataframe values.