When using the S3Upload task from the task library, I'm getting an error: "AttributeError: 'str' object has no attribute 'bucket'" - how to fix this?

[anna_geller]

This error occurs when setting run()-specific attributes within task initialization. The Slack discussion below provides more info.

View in #prefect-server on Slack

@Henrietta_Salonen: Hello, This may be something simple that I’m just totally overlooking but trying to use the s3.s3Upload.run in my flow in the following way:

with 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: You shouldn’t call the run() 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: Hey do you mean like this:

with Flow("test") as flow:
    s3.S3Upload(data, credentials="AWS_CREDENTIALS", bucket='bucket_name', compression='gzip')

flow.run()

@Kevin_Kho: no you need 2 parenthesis. either:

s = S3Upload()
with Flow(..) as flow:
    s()

or:

with Flow(..) as flow:
    S3Upload()()

@Henrietta_Salonen: cheers, that was it! Thank you

@Kevin_Kho: Nice!