faint-smartphone-23356
05/23/2022, 4:46 PMfaint-smartphone-23356
05/23/2022, 4:49 PMfrom our.codebase.task import task, OurParameterType, OurTaskResult
def test_our_task():
@workflow
def do_workflow(arg1: FlyteDirectory, arg2: OurParameterType) -> OurTaskResult:
return task(arg1, arg2)
arg1 = foo
arg2 = bar
ret: OurTaskResult = do_workflow(arg1, arg2)
faint-smartphone-23356
05/23/2022, 4:49 PMno parameter named arg2
2. VoidPromise is incompatible with OurTaskResult
faint-smartphone-23356
05/23/2022, 4:50 PMdo_work
be something else?faint-smartphone-23356
05/23/2022, 4:52 PMOurTaskResult
is essentially a:
@dataclass_json
@dataclass
class FlyteResult:
result: <our dc>
Where our dc
is passed during module evaluationhigh-accountant-32689
05/23/2022, 5:07 PMdo_workflow
with:
do_workflow(arg1=arg1, arg2=arg2)
As for #2, this is a byproduct of the flytekit decorators. I think we can do something there, but will require a few changes.faint-smartphone-23356
05/23/2022, 5:18 PMfaint-smartphone-23356
05/23/2022, 5:18 PMfaint-smartphone-23356
05/23/2022, 5:19 PMhigh-accountant-32689
05/23/2022, 5:21 PMfaint-smartphone-23356
05/23/2022, 5:21 PMfaint-smartphone-23356
05/23/2022, 5:21 PMfaint-smartphone-23356
05/23/2022, 5:21 PMhigh-accountant-32689
05/23/2022, 5:22 PMhigh-accountant-32689
05/23/2022, 5:22 PMfaint-smartphone-23356
05/23/2022, 5:22 PMhigh-accountant-32689
05/23/2022, 5:22 PMfaint-smartphone-23356
05/23/2022, 5:25 PMhigh-accountant-32689
05/23/2022, 5:25 PMfaint-smartphone-23356
05/23/2022, 5:56 PMhigh-accountant-32689
05/23/2022, 7:29 PM