Frank Shen
11/11/2022, 8:36 PMin wf() team: abc
in wf() a: 3
in t1() team: abc_3
in t1() a: 3
result from wf(): ('abc_3', 3)
Ketan (kumare3)
Greg Gydush
11/18/2022, 6:50 PM.with_overrides
on a task in a workflow using parameters passed to the workflow. Example:
@workflow
def test_workflow(mem: str, cpu: float) -> None:
test_task().with_overrides(
requests=Resources(cpu=cpu, mem=mem),
limits=Resources(cpu=cpu, mem=mem),
)
Wrapping test_task in a dynamic works, but wondering if there’s an alternativeFrank Shen
11/18/2022, 10:05 PM@workflow
def test_workflow(mem: str, cpu: float) -> None:
test_task(cpu=cpu, mem=mem).with_overrides(
requests=Resources(cpu=cpu, mem=mem),
Greg Gydush
11/18/2022, 10:56 PMFile "/fn/lib/venv/lib/python3.10/site-packages/flytekit/models/task.py", line 56, in to_flyte_idl
return _core_task.Resources.ResourceEntry(name=self.name, value=self.value)
TypeError: Promise(node:.mem) has type Promise, but expected one of: bytes, unicode
make: *** [flyte-register] Error 1
Still the same issue - it looks like all workflow parameters are Promises, and with_overrides
is not expecting thatFrank Shen
11/18/2022, 10:58 PM.with_overrides() is not inside the task function.