acoustic-carpenter-78188
04/14/2023, 4:13 PMValueError: Empty module name
args:[24 items
0:"pyflyte-fast-execute"
1:"--additional-distribution"
2:"s3://...."
3:"--dest-dir"
4:"{{ .dest_dir }}"
5:"--"
6:"pyflyte-execute"
7:"--inputs"
8:"{{.input}}"
9:"--output-prefix"
10:"{{.outputPrefix}}"
11:"--raw-output-data-prefix"
12:"{{.rawOutputDataPrefix}}"
13:"--checkpoint-path"
14:"{{.checkpointOutputPrefix}}"
15:"--prev-checkpoint"
16:"{{.prevCheckpointPrefix}}"
17:"--resolver"
18:"flytekit.core.python_auto_container.default_task_resolver"
19:"--"
20:"task-module"
21:""
22:"task-name"
23:"my_task"
]
Expected behavior
The module path is detected and included in the generated command args.
Additional context to reproduce
To reproduce, run the following python script
import flytekit
import flytekit.remote
import flytekit.configuration as flyte_config
from flytekit.tools import repo
import uuid
@flytekit.task
def my_task():
print('my task')
def main(remote_endpoint='dns:///localhost:8089'):
remote = flytekit.remote.FlyteRemote(
config=flyte_config.Config.for_endpoint(endpoint=remote_endpoint, insecure=True),
default_project="flytesnacks",
default_domain="development",
)
detected_root = repo.find_common_root(["."])
print(f"detected root: {detected_root}")
_, native_url = remote.fast_package(detected_root)
fast_serialization_settings = flyte_config.FastSerializationSettings(
enabled=True,
destination_dir=".",
distribution_location=native_url,
)
task = remote.register_task(
my_task,
version=str(uuid.uuid4()).lower().replace("-", ""),
serialization_settings=flyte_config.SerializationSettings(
image_config=flyte_config.ImageConfig.auto_default_image(),
fast_serialization_settings=fast_serialization_settings,
),
)
print(task)
if __name__ == "__main__":
main()
Screenshots
No response
Are you sure this issue hasn't been raised already?
☑︎ Yes
Have you read the Code of Conduct?
☑︎ Yes
flyteorg/flyte