Kelsey Messer
01/18/2022, 8:23 PMflytekit==0.24.0
Yee
Kelsey Messer
01/18/2022, 9:14 PMonemodel.models.label_market_share._flyte.label_market_share_standalone
and its signature is
@workflow
def label_market_share_standalone(
shared_params: dict,
specific_model_params: typing.Dict[str, pd.DataFrame],
) -> typing.Tuple[Schema, Schema]:
the signature for the bottom one is
@workflow
def msr_standalone(
shared_params: dict,
specific_model_params: typing.Dict[str, pd.DataFrame],
) -> Schema:
katrina
Kelsey Messer
01/18/2022, 9:24 PMlabel-market-share-forecast
node in the first red box should read onemodel.models.label_market_share._flyte.label_market_share_task
as its path (and it's a python task, not a sub-workflow). its signature is
@task(
requests=Resources(mem="1Gi", cpu="250m"),
limits=Resources(mem="2Gi", cpu="1"),
)
def label_market_share_task(
shared_params: dict,
parameters: typing.Dict[str, pd.DataFrame],
) -> Schema:
similarly in the bottom red box the msr-forecast
should read onemodel.models.msr._flyte.msr_task
as its path (and it's a python task, not a sub-workflow). its signature is
@task(
cache=True,
cache_version=environ["VERSION"],
requests=Resources(mem="1Gi", cpu="250m"),
limits=Resources(mem="2Gi", cpu="1"),
)
def msr_task(
shared_params: dict,
parameters: typing.Dict[str, pd.DataFrame],
) -> Schema:
Jason Porter
01/18/2022, 9:26 PMKelsey Messer
01/18/2022, 9:27 PMJason Porter
01/18/2022, 9:30 PMKelsey Messer
01/18/2022, 9:30 PMJason Porter
01/18/2022, 9:31 PMYee
<http://localhost:30081/api/v1/workflows/flytesnacks/development/core.control_flow.subworkflows.nested_parent_wf/98756d945109acf6e08a022563596d22b0150ee7>
something like thatn3
node, is it label-market-share-forecast
?Kelsey Messer
01/18/2022, 10:34 PMYee
Nastya Rusina
01/18/2022, 10:54 PMYee
Kelsey Messer
01/18/2022, 10:58 PMYee
Sören Brunk
01/19/2022, 7:30 AMYee
Nastya Rusina
01/27/2022, 1:14 AMYee
Nastya Rusina
01/31/2022, 11:00 PMKetan (kumare3)
Nastya Rusina
02/11/2022, 12:52 AMKelsey Messer
02/11/2022, 2:08 PM