JP Kosymna
02/17/2022, 7:13 PMtest_fixed_array_map_task
completes successfully in a few seconds, while workflow test_empty_array_map_task
hangs indefinitely with the status QUEUED.
from flytekit import map_task, task, workflow
@task
def say_hello(name: str) -> str:
message = f"hello {name}"
print(message)
return message
@workflow
def test_empty_array_map_task() -> list[str]:
names: list[str] = []
messages = map_task(say_hello)(name=names)
return messages
@workflow
def test_fixed_array_map_task() -> list[str]:
names: list[str] = ['jp', 'ketan']
messages = map_task(say_hello)(name=names)
return messages
Let me know if there is any additional information I can provide. Thanks{
"config": {},
"id": {
"resourceType": 1,
"project": "flytesnacks",
"domain": "development",
"name": "flyte_workflows.example.mapper_say_hello_3",
"version": "v60"
},
"type": "container_array",
"metadata": {
"runtime": {
"type": 1,
"version": "0.26.1",
"flavor": "python"
},
"retries": {}
},
"interface": {
"inputs": {
"variables": {
"name": {
"type": {
"collectionType": {
"simple": 3
}
},
"description": "name"
}
}
},
"outputs": {
"variables": {
"o0": {
"type": {
"collectionType": {
"simple": 3
}
},
"description": "o0"
}
}
}
},
"taskTypeVersion": 1,
"container": {
"command": [],
"args": [
"pyflyte-map-execute",
"--inputs",
"{{.input}}",
"--output-prefix",
"{{.outputPrefix}}",
"--raw-output-data-prefix",
"{{.rawOutputDataPrefix}}",
"--resolver",
"flytekit.core.python_auto_container.default_task_resolver",
"--",
"task-module",
"flyte_workflows.example",
"task-name",
"say_hello"
],
"env": [
{
"key": "FLYTE_INTERNAL_IMAGE",
"value": "<http://518673686532.dkr.ecr.us-west-2.amazonaws.com/flyte/test:v60|518673686532.dkr.ecr.us-west-2.amazonaws.com/flyte/test:v60>"
}
],
"config": [],
"ports": [],
"image": "<http://518673686532.dkr.ecr.us-west-2.amazonaws.com/flyte/test:v60|518673686532.dkr.ecr.us-west-2.amazonaws.com/flyte/test:v60>",
"resources": {
"requests": [],
"limits": []
}
}
}
Yee
JP Kosymna
02/17/2022, 7:35 PM{
"json": {
"src": "controller.go:138"
},
"level": "info",
"msg": "==> Enqueueing workflow [flytesnacks-development/l7mc2614ly]",
"ts": "2022-02-17T19:33:52Z"
}
Dan Rammer (hamersaw)
02/17/2022, 8:14 PMJP Kosymna
02/17/2022, 8:18 PMDan Rammer (hamersaw)
02/17/2022, 8:18 PMJP Kosymna
02/17/2022, 8:20 PMKetan (kumare3)
JP Kosymna
02/17/2022, 8:35 PMDan Rammer (hamersaw)
02/17/2022, 8:54 PMJP Kosymna
02/17/2022, 9:32 PMKetan (kumare3)