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

Anirudh Sridhar

09/28/2023, 11:30 AM
Hey team i am facing this issue while running ray on eks cluster can someone help me out
Copy code
Traceback (most recent call last):

      File "/usr/local/lib/python3.9/site-packages/flytekit/exceptions/scopes.py", line 206, in user_entry_point
        return wrapped(*args, **kwargs)
      File "/root/wf.py", line 177, in main_task_list
        outputs = [item for sublist in ray.get(outputs) for item in sublist]
      File "/usr/local/lib/python3.9/site-packages/ray/_private/auto_init_hook.py", line 24, in auto_init_wrapper
        return fn(*args, **kwargs)
      File "/usr/local/lib/python3.9/site-packages/ray/_private/client_mode_hook.py", line 103, in wrapper
        return func(*args, **kwargs)
      File "/usr/local/lib/python3.9/site-packages/ray/_private/worker.py", line 2547, in get
        raise value.as_instanceof_cause()

Message:

    [36mray::main_task()[39m (pid=87, ip=10.2.183.131)
RuntimeError: The remote function failed to import on the worker. This may be because needed library dependencies are not installed in the worker environment:

[36mray::main_task()[39m (pid=87, ip=10.2.183.131)
ModuleNotFoundError: No module named 'wf'
k

Kevin Su

09/28/2023, 3:58 PM
How do you register the workflow
Pyflyte run?
a

Anirudh Sridhar

09/28/2023, 3:58 PM
yes
so it worked for sample=1
k

Kevin Su

09/28/2023, 3:59 PM
Could you show me your docker file again
a

Anirudh Sridhar

09/28/2023, 3:59 PM
and started failing for sample >1
i did using imagespec
k

Kevin Su

09/28/2023, 4:00 PM
hmm, could you share your workflow again
a

Anirudh Sridhar

09/28/2023, 4:01 PM
as i told i can just screen share i cant share as it is company code