Oluremi Akinwale
08/31/2022, 10:48 AMRahul Kadam
08/31/2022, 11:18 AMFailed to start task for flow run ad860ca0-61df-4055-b3f6-7f48c2d9ead4. Failures: [{'arn': 'arn:aws:ecs:us-east-1:XXXXXXXXXXXX:container-instance/XXXXXXXXXXXX', 'reason': 'RESOURCE:CPU'}, {'arn': 'arn:aws:ecs:us-east-1:XXXXXXXXXXXX:container-instance/XXXXXXXXXXXX', 'reason': 'RESOURCE:MEMORY'}, {'arn': 'arn:aws:ecs:us-east-1:XXXXXXXXXXXX:container-instance/XXXXXXXXXXXX', 'reason': 'RESOURCE:MEMORY'}]
Understandably, its because enough resources are not available on ECS nodes to schedule the tasks when launch type is EC2.
But as per my understanding, in such cases the ECS task should get scheduled with "Provisioning" state, and ECS cluster should scale out and add more instances after which the task would run. However in our case we see above error and the task just fails to schedule.
Is there a specific parameter we are missing which will provide the ECS feature that i mentioned above ? or this is the expected pattern ?Timo
08/31/2022, 11:31 AMprefect deployment build myflow.py:myflow \
--path /prefect/flows/myflow \
-ib docker-container/dev-image \
--name local_docker \
--skip-upload \
--apply
After running the deployment it breaks with "no basic auth credentials".
Inspecting the "Docker Container" block shows that it should use the defined registry block. Double checked the credentials multiple times and successfully logged in with docker login...
I tried the same on 2.2.0 with the same error after executing the deployment :-(Jeff Hale
08/31/2022, 11:36 AMAdam Brusselback
08/31/2022, 12:29 PMMohammad Tami
08/31/2022, 2:23 PMJosh Paulin
08/31/2022, 2:32 PMPrakash Rai
08/31/2022, 2:57 PMJason
08/31/2022, 3:21 PMKhuyen Tran
08/31/2022, 3:31 PMTomas Moreno
08/31/2022, 4:16 PMElio
08/31/2022, 4:18 PMhttps://puu.sh/Jj0Q7/77bd248705.png▾
Blake Stefansen
08/31/2022, 4:32 PM.prefectignore
and no, it is not ignoring anything critical. Is this a bug?Maria
08/31/2022, 5:57 PMPREFECT_API_URL
what other things need to be configured? I keep getting [Errno -2] Name or service not known
I have prefect orion set up with helm in EKSMarc-Antoine Bélanger
08/31/2022, 6:31 PM@flow
def my_flow():
return "hola"
Using the OrionClient I am able to read the states of a flow run using orion_client.read_flow_run_states(flow_run_id)
. The last state is COMPLETED
and has a data
attribute that is NOT None
. For example the data attribute value is:
state.data = _Result(key='b1fd11041ae54cfcbb9b41ec938ff0cf', filesystem_document_id=UUID('bd1ed851-82d2-4f87-b11c-be04a80634af'))
What does this represents? Why don't I have state.data = "hola"
instead? How do I get my flow return data from the OrionClient?
Thanks a lot!Luis Diaz
08/31/2022, 6:54 PMKhuyen Tran
08/31/2022, 6:54 PMMansour Zayer
08/31/2022, 7:05 PM../flow_1.py
@task(my_task)
def my_task(param)
.................................
from flow_1.py import my_task
../flow_2.py
@Flow(some_flow):
my_task(param_1)
my_task(param_2, upstream_tasks=[my_task])
Since the 2 tasks in my Flow in flow_2 have the same name, would upstream_tasks
work? Is there a better way to do this?
Thank youJai P
08/31/2022, 7:07 PMMars
08/31/2022, 8:08 PMGET /collection
to list all members of a collection, such as GET /api/flow_runs/
. However, the server, OpenAPI spec, and example at http://localhost:4200/docs#/ say that I must supply an id to the collection, such as GET /api/flow_runs/1234
. What the correct way to fetch the full list of collection members?Emerson Franks
08/31/2022, 8:39 PMSam Garvis
08/31/2022, 8:55 PMTony Yun
08/31/2022, 9:57 PMAdam Brusselback
08/31/2022, 10:08 PMJovan Sakovic
08/31/2022, 11:13 PMlocalhost/4200
that we can’t reach without connecting to the VM etc..Matt Fysh
09/01/2022, 1:03 AMDaskTaskRunner
working in this tutorial: https://docs.prefect.io/tutorials/execution/#parallel-execution
I get a bunch of errors, e.g. “no active connection” , or “TypeError: DaskTaskRunner.submit() got an unexpected keyword argument ‘key’”Adam Brusselback
09/01/2022, 1:45 AMArchitha Rao
09/01/2022, 6:52 AMKonstantinos
09/01/2022, 7:17 AMRobert Kowalski
09/01/2022, 7:36 AMRobert Kowalski
09/01/2022, 7:36 AMJeff Hale
09/01/2022, 12:07 PMRobert Kowalski
09/01/2022, 12:07 PMBianca Hoch
09/01/2022, 2:22 PMRobert Kowalski
09/01/2022, 2:28 PMBianca Hoch
09/01/2022, 4:35 PMRobert Kowalski
09/01/2022, 5:01 PM