Choenden Kyirong04/17/2023, 9:37 PM
to persist results of certain tasks due to them producing large amounts of data. However, i’m running into an issue when trying to use: _`persist_result=True` and
. I’m following along the documentation and doing the following:
However, i’m running into this error when
... from prefect.filesystems import S3 ... @task(name="<task_name>", persist_result=True, result_storage_key="<key_name>") def task_1(...): ... @flow(task_runner=DaskTaskRunner, persist_result=True, result_storage=S3(bucket_path="<bucket_path>"), name="<name>") def flow(...): ...
I’m wondering if i’m using this correctly? I have registered the
Crash detected! Execution was interrupted by an unexpected exception: botocore.exceptions.NoCredentialsError: Unable to locate credentials
block with the proper credentials and the documented example does not show a need to
the block and just uses it like the above. It seems as though the call to
is unable to identify or locate any credentials. Any advice or help would be greatly appreciated!