Ben Muller
02/23/2022, 10:21 PMdata_update = Parameter("data_update", required=True)
put_dateformatted_data_to_s3.map(
df=data,
bucket_name=unmapped(get_key_value("bucket")),
key_name=unmapped("key"),
suffix=unmapped(f"_{data_update}"),
)
This writes a file with a name of 19_<Parameter: data_update>.parquet
I want it to be the actual param provided in the flowKevin Kho
02/23/2022, 10:24 PMBen Muller
02/23/2022, 10:25 PM