Romain Vincent
02/27/2024, 3:16 PMMarvin
02/27/2024, 3:17 PMAmazonECS_FullAccess
permission and create an access key for the user.
4. Back in Prefect Cloud, name your credentials block and enter the AWS Access Key ID and AWS Secret Access Key in the relevant fields.
5. Proceed to configure your ECS task and capacity provider settings within AWS.
Unfortunately, the current documentation doesn't provide a detailed step-by-step guide specifically for using ECS work pools with EC2 capacity providers. However, you should be able to set this up by applying AWS ECS and EC2 knowledge to configure tasks and capacity providers to work with Prefect workflows. If more detailed Prefect Cloud instructions are needed, it might be helpful to contact Prefect support or community for further assistance.
Relevant resources:
- Guide on Push Work Pools
- Prefect Deploy
If you encounter issues or need more specifics, it would be helpful to check the Prefect community or GitHub issues.
Would you like me to search GitHub issues for more details on integrating ECS work pools with EC2 capacity providers?Nate
02/27/2024, 3:21 PMRomain Vincent
02/27/2024, 3:24 PMFailed to submit flow run 'bd5c36d8-4d2b-4de8-a67a-0b06b919f0ae' to infrastructure.
Traceback (most recent call last):
File "/usr/local/lib/python3.10/site-packages/tenacity/__init__.py", line 382, in __call__
result = fn(*args, **kwargs)
File "/usr/local/lib/python3.10/site-packages/prefect_aws/workers/ecs_worker.py", line 1557, in _create_task_run
return ecs_client.run_task(**task_run_request)["tasks"][0]
IndexError: list index out of range
The above exception was the direct cause of the following exception:
Traceback (most recent call last):
File "/usr/local/lib/python3.10/site-packages/prefect/workers/base.py", line 896, in _submit_run_and_capture_errors
result = await self.run(
File "/usr/local/lib/python3.10/site-packages/prefect_aws/workers/ecs_worker.py", line 598, in run
) = await run_sync_in_worker_thread(
File "/usr/local/lib/python3.10/site-packages/prefect/utilities/asyncutils.py", line 95, in run_sync_in_worker_thread
return await anyio.to_thread.run_sync(
File "/usr/local/lib/python3.10/site-packages/anyio/to_thread.py", line 33, in run_sync
return await get_asynclib().run_sync_in_worker_thread(
File "/usr/local/lib/python3.10/site-packages/anyio/_backends/_asyncio.py", line 877, in run_sync_in_worker_thread
return await future
File "/usr/local/lib/python3.10/site-packages/anyio/_backends/_asyncio.py", line 807, in run
result = context.run(func, *args)
File "/usr/local/lib/python3.10/site-packages/prefect_aws/workers/ecs_worker.py", line 761, in _create_task_and_wait_for_start
self._report_task_run_creation_failure(configuration, task_run_request, exc)
File "/usr/local/lib/python3.10/site-packages/prefect_aws/workers/ecs_worker.py", line 757, in _create_task_and_wait_for_start
task = self._create_task_run(ecs_client, task_run_request)
File "/usr/local/lib/python3.10/site-packages/tenacity/__init__.py", line 289, in wrapped_f
return self(f, *args, **kw)
File "/usr/local/lib/python3.10/site-packages/tenacity/__init__.py", line 379, in __call__
do = self.iter(retry_state=retry_state)
File "/usr/local/lib/python3.10/site-packages/tenacity/__init__.py", line 326, in iter
raise retry_exc from fut.exception()
tenacity.RetryError: RetryError[]
Romain Vincent
02/27/2024, 3:26 PMNate
02/27/2024, 3:27 PMNate
02/27/2024, 3:29 PMRomain Vincent
02/27/2024, 3:30 PMRomain Vincent
02/27/2024, 3:31 PMRomain Vincent
02/27/2024, 3:40 PM