https://flyte.org logo
#ask-the-community
Title
# ask-the-community
k

Kamakshi Muthukrishnan

11/07/2022, 3:58 PM
@Ketan (kumare3) .Yes ray error when I run in flyte. this is a single node
k

Ketan (kumare3)

11/07/2022, 3:59 PM
k

Kamakshi Muthukrishnan

11/07/2022, 4:09 PM
I am using @task( task_config=RayJobConfig( head_node_config=HeadNodeConfig(ray_start_params={"block": "True"}), worker_node_config=[ WorkerNodeConfig( group_name="ray-group", replicas=5, min_replicas=2, max_replicas=10 ) ], runtime_env={'env_vars': {'__MODIN_AUTOIMPORT_PANDAS__': '1'},"pip": ["numpy", "modin"]}, ) )
message has been deleted
Is it still resource to be increased?? how should i add it here
d

Dan Rammer (hamersaw)

11/07/2022, 4:53 PM
cc @Kevin Su - ray worker resource configuration
k

Kevin Su

11/07/2022, 6:03 PM
you could update the worker’s resource by updating the
limit
and
request
in the
@task
.
Copy code
@task(task_config=RayJobConfig(...), requests=Resources(cpu="10"), limits=Resources(gpu="2"))