Sacha Ventura
03/29/2022, 5:36 AMSacha 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()
Sacha Ventura
03/29/2022, 5:37 AMSacha Ventura
03/29/2022, 5:39 AMError downloading Flow from S3: Unable to locate credentials
by providing all the possible combinations of AWS env vars in the task definition container.Sacha Ventura
03/29/2022, 5:40 AM15: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'")
Sacha Ventura
03/29/2022, 5:41 AMSacha Ventura
03/29/2022, 5:41 AMprefecthq/prefect:1.1.0-python3.8
as agent image)Anna Geller
ecs
in its name:
https://github.com/anna-geller/packaging-prefect-flows/tree/master/flowsAnna Geller
Anna Geller
Sacha Ventura
04/06/2022, 2:20 AMSacha Ventura
04/06/2022, 11:21 PM