bruno.corucho07/23/2020, 9:32 AM
Should I return these partitions and do the delaying and computing using a Prefect's map() from within the flow's scope definition? Thanks in advance! 🙂 And have a great weekend!
df = read_sql_table(table='peanuts', uri=connection, index_col="peanut_id", columns=["peanut_details, peanut_date"], npartitions=1000)