most-gold-65483
02/24/2023, 7:17 AMwith_override
feature in flytekit. The example demonstrate overriding task’s cpu & memory limits.
@workflow
def my_pipeline(x: typing.List[int]) -> int:
return square_1(x=count_unique_numbers_1(x=x)).with_overrides(
limits=Resources(cpu="6", mem="500Mi")
)
Can it be done by using workflow input. e.g.
@workflow
def my_pipeline(x: typing.List[int], cpu: str, mem: str) -> int:
return square_1(x=count_unique_numbers_1(x=x)).with_overrides(
limits=Resources(cpu=cpu, mem=mem)
)
?glamorous-carpet-83516
02/24/2023, 10:21 AMmost-gold-65483
02/24/2023, 11:07 AMdynamically
here refers to execution overrides. Thanks for clarifying!freezing-airport-6809
rich-garden-69988
02/24/2023, 8:55 PMfreezing-airport-6809