Jason
05/12/2022, 9:14 PMAnna Geller
05/12/2022, 9:16 PMJason
05/12/2022, 9:16 PMtask.map([*tupled_data_frames, data_frame2, data_frame3])
Anna Geller
05/12/2022, 9:19 PMJason
05/12/2022, 9:20 PMAnna Geller
05/12/2022, 9:22 PMJason
05/12/2022, 9:23 PMwith Flow(
FLOW_NAME,
storage=Config.storage(project=PROJECT, file_name=FILE_NAME),
result=S3Result(bucket="EDITED"),
run_config=Config.run(),
) as flow:
with case(save_snowflake, True): # type: ignore
load_snowflake.map(
data_payload=[*reservations, owners, properties, amenities],
drop=unmapped(drop_snowflake),
)
nout
in the reservations
task, which is perhaps why it works? idk.Anna Geller
05/12/2022, 9:25 PM