seunggs
09/16/2022, 2:35 AM[4/4] currentAttempt done. Last Error: USER::Pod failed. No message received from kubernetes.
[a29fz6979nbn4dxsr7km-n0-3] terminated with exit code (1). Reason [Error]. Message:
Traceback (most recent call last):
File "/opt/venv/bin/pyflyte-execute", line 8, in <module>
sys.exit(execute_task_cmd())
File "/opt/venv/lib/python3.8/site-packages/click/core.py", line 1130, in __call__
return self.main(*args, **kwargs)
File "/opt/venv/lib/python3.8/site-packages/click/core.py", line 1055, in main
rv = self.invoke(ctx)
File "/opt/venv/lib/python3.8/site-packages/click/core.py", line 1404, in invoke
return ctx.invoke(self.callback, **ctx.params)
File "/opt/venv/lib/python3.8/site-packages/click/core.py", line 760, in invoke
return __callback(*args, **kwargs)
File "/opt/venv/lib/python3.8/site-packages/flytekit/bin/entrypoint.py", line 470, in execute_task_cmd
_execute_task(
File "/opt/venv/lib/python3.8/site-packages/flytekit/exceptions/scopes.py", line 160, in system_entry_point
return wrapped(*args, **kwargs)
File "/opt/venv/lib/python3.8/site-packages/flytekit/bin/entrypoint.py", line 348, in _execute_task
_handle_annotated_task(ctx, _task_def, inputs, output_prefix)
File "/opt/venv/lib/python3.8/site-packages/flytekit/bin/entrypoint.py", line 291, in _handle_annotated_task
_dispatch_execute(ctx, task_def, inputs, output_prefix)
File "/opt/venv/lib/python3.8/site-packages/flytekit/bin/entrypoint.py", line 80, in _dispatch_execute
logger.debug(f"Starting _dispatch_execute for {task_def.name}")
AttributeError: 'function' object has no attribute 'name'
Eduardo Apolinario (eapolinario)
09/16/2022, 2:37 AMseunggs
09/16/2022, 2:39 AM/project-root/flyte/workflows
, I have test_wf.py
with the following codefrom flytekit import Resources, task, workflow
from src.test_tasks import add_one
from src.test_tasks import double
add_one_task=task(requests=Resources(cpu="1"),limits=Resources(cpu="1"),retries=3)(add_one)
double_task=task(requests=Resources(cpu="1"),limits=Resources(cpu="1"),retries=3)(double)
@workflow
def test_wf_1(x:int):
add_one_task_output_=add_one_task(x=x)
double_task_output_=double_task(x=add_one_task_output_)
return {"result":{"double_task":double_task_output_}}
/project-root/src/test_tasks.py
, I have the following code:def add_one(x: int) -> int:
return x + 1
def double(x: int) -> int:
return x * 2
/project-root
I’m running pyflyte package …
and then flytectl register…
Eduardo Apolinario (eapolinario)
09/16/2022, 3:20 AM...
@workflow
def test_wf_1(x:int):
add_one_task=task(requests=Resources(cpu="1"),limits=Resources(cpu="1"),retries=3)(add_one) double_task=task(requests=Resources(cpu="1"),limits=Resources(cpu="1"),retries=3)(double)
add_one_task_output_=add_one_task(x=x)
double_task_output_=double_task(x=add_one_task_output_)
return {"result":{"double_task":double_task_output_}}
seunggs
09/16/2022, 3:21 AMEduardo Apolinario (eapolinario)
09/16/2022, 3:23 AM@task
makes an assumption that it will be invoked inside a workflowseunggs
09/16/2022, 3:26 AMEduardo Apolinario (eapolinario)
09/16/2022, 3:29 AMfrom flytekit import task, workflow, Resources
def add_one(x: int) -> int:
return x + 1
@workflow
def test_wf_1(x:int):
add_one_task=task(add_one, requests=Resources(cpu="1"),limits=Resources(cpu="1"),retries=3)
# This also works
# add_one_task=task(requests=Resources(cpu="1"),limits=Resources(cpu="1"),retries=3)(add_one)
add_one_task_output_=add_one_task(x=x)
return {"result":{"add_one_task_output":add_one_task_output_}}
seunggs
09/16/2022, 3:33 AMEduardo Apolinario (eapolinario)
09/16/2022, 3:34 AM@workflow
(this is not supported today).seunggs
09/16/2022, 3:35 AMEduardo Apolinario (eapolinario)
09/16/2022, 3:35 AMseunggs
09/16/2022, 3:35 AMEduardo Apolinario (eapolinario)
09/16/2022, 3:36 AM@task
decorator in a @workflow
@task
thoughseunggs
09/16/2022, 3:36 AMEduardo Apolinario (eapolinario)
09/16/2022, 3:38 AMseunggs
09/16/2022, 3:38 AMEduardo Apolinario (eapolinario)
09/16/2022, 3:38 AM@workflow
smells like python but it's indeed a DSL defined in flytekitseunggs
09/16/2022, 3:39 AMEduardo Apolinario (eapolinario)
09/16/2022, 3:39 AMseunggs
09/16/2022, 3:40 AMEduardo Apolinario (eapolinario)
09/16/2022, 3:41 AM