Henrietta Salonen
02/14/2022, 2:32 PMwith Flow("test") as flow:
s3.S3Upload.run(data, credentials="AWS_CREDENTIALS", bucket='bucket_name', compression='gzip')
flow.run()
Data is json string.
I keep on getting this error AttributeError: 'str' object has no attribute 'bucket'
Kevin Kho
02/14/2022, 2:34 PMrun()
method inside the Flow. I don’t know if this will help but try:
with Flow(..) as flow:
S3Upload(init_stuff_here)(run_stuff_here)
Henrietta Salonen
02/14/2022, 2:38 PMwith Flow("test") as flow:
s3.S3Upload(data, credentials="AWS_CREDENTIALS", bucket='bucket_name', compression='gzip')
flow.run()
Kevin Kho
02/14/2022, 2:40 PMs = S3Upload()
with Flow(..) as flow:
s()
or:
with Flow(..) as flow:
S3Upload()()
Henrietta Salonen
02/14/2022, 2:54 PMKevin Kho
02/14/2022, 3:00 PM