Hi I was wondering if anyone has run into `ValueError Empty

Question

Hi I was wondering if anyone has run into `ValueError Empty module name` when running a `map task ` with flytekit and trying to load the actual `task` object More details below arrow down cc < Heidi Hurst>

Derek Yu · Answer

When calling `map task` with flytekit we are seeing this `ValueError Empty module name` ``` 546 execute map task root micromamba envs xxx lib python3 10 site packages flytekit e xceptions scopes py 160 in system entry point 160 return wrapped args kwargs root micromamba envs xxx lib python3 10 site packages flytekit b in entrypoint py 394 in execute map task 394 map task = mtr load task loader args=resolver args max concur root micromamba envs xxx lib python3 10 site packages flytekit c ore utils py 295 in wrapper 295 return func args kwargs root micromamba envs xxx lib python3 10 site packages flytekit c ore map task py 368 in load task 368 resolver obj = load object from module resolver root micromamba envs xxx lib python3 10 site packages flytekit t ools module loader py 43 in load object from module 43 class obj mod = importlib import module join class obj mod root micromamba envs xxx lib python3 10 importlib init py 12 6 in import module 126 return bootstrap gcd import name level package level in gcd import 1047 in sanity check 981 ValueError Empty module name```

Yee · Answer

that feels like the underlying task is not accessible

Yee · Answer

where do you have that defined

Yee · Answer

can you copy paste more code is this fast register

Derek Yu · Answer

The workflows are registered by running `flytectl register files` `map task` is invoked as such ``` result = map task foo task concurrency=5 a = x ``` in a workflow defined in directory `flyte a b tasks` `foo task` is defined in a file in the same directory `flyte a b tasks` The failing command `pyflyte map execute` in the logs has ` input` ` task module ` `flyte a b tasks` Here is the structure of the error message ```CalledProcessError Command pyflyte map execute inputs xxx output prefix xxx raw output data prefix xxx checkpoint path xxx prev checkpoint dynamic addl distro xxx dynamic dest dir resolver MapTaskResolver vars resolver flytekit core python auto container default task resolver task module flyte a b tasks task name foo task ``` Thanks Yee let me know if there s anything else I can provide that would be helpful to troubleshoot

Samhita Alla · Answer

I think the task module should be `flyte a b tasks lt module gt ` Is it possible for you to share the directory structure and the serialization amp registration commands you re running

Derek Yu · Answer

Thanks Samhita here s the dir structure workflow defined in `flyte a b tasks workflows py` and the workflow calls a map task ``` workflow def foo workflow result = map task foo task concurrency=5 a = x ``` task is defined in `flyte a b tasks tasks py` Serialization registration commands ``` pyflyte k a k flyte a serialize image xxx workflows f tmp workflows amp amp flytectl admin endpoint dns xxx register files tmp workflows p foo d bar version= xxx ```

Samhita Alla · Answer

Can you try `pyflyte package` instead of `pyflyte serialize`

Heidi Hurst · Answer

FYI dropping back down to Flytekit 1 4 2 resolved this issue so I suspect this is something that s either broken or changed with the recent releases the above error was encountered with flytekit 1 6 1

Samhita Alla · Answer

cc < Eduardo Apolinario eapolinario >

Eduardo Apolinario (eapolinario) · Answer

< Derek Yu> < Heidi Hurst> I m having trouble reproing this Can you give us more details For example can you show the dir structure by running `tree` at the root of the repo Also what s the type of `x` in `foo workflow`

Heidi Hurst · Answer

Sure Thanks for following up < Eduardo Apolinario eapolinario > slightly smiling face I ve been able to construct a small example which shows the same error Files `flyte a b workflows py` ``` workflow def repro issue workflow gt List int foo = foo task bar = map task bar task concurrency=3 number=foo return bar``` `flyte a b tasks py` ``` task def foo task gt List int return 1 2 3 task def bar task number int gt int return number + 1``` In this example the type of data in the map task is `List int ` I ve confirmed that this fails with both regular registration and fast registration This also seems to fail when both the tasks and workflows are in the same file thinking face In the screenshot included you can also see that the map task has a different naming convention than I would have expected from past flytekit versions as well although that might be a red herring Happy to open an issue or file a bug report if that would be helpful pray