Sacha Ventura
03/29/2022, 5:36 AMimport prefect
from prefect import task, Flow
from prefect.storage import S3
@task
def print_task():
logger = prefect.context.get("logger")
<http://logger.info|logger.info>(f'hello world')
with Flow("hello-flow") as flow:
print_task()
flow.storage = S3(bucket="****")
if __name__ == '__main__':
flow.run()
Error downloading Flow from S3: Unable to locate credentials
by providing all the possible combinations of AWS env vars in the task definition container.15:58:12
INFO
agent
Submitted for execution: Task ****
15:58:47
INFO
S3
Downloading flow from s3://***/hello-flow/2022-03-29t04-10-25-834594-00-00
15:58:47
ERROR
S3
Error downloading Flow from S3: 'str' object has no attribute 'get'
15:58:48
ERROR
execute flow-run
Failed to load and execute flow run: AttributeError("'str' object has no attribute 'get'")
prefecthq/prefect:1.1.0-python3.8
as agent image)Anna Geller
03/29/2022, 9:48 AMecs
in its name:
https://github.com/anna-geller/packaging-prefect-flows/tree/master/flowsSacha Ventura
04/06/2022, 2:20 AM