Thomas Blom
11/27/2023, 11:34 PM# inside an @dynamic workflow...
some_result = first_task(in=inputs)
mem_required = some_result.some_computed_metric * 8 # oops, can't de-ref here, some_result is a promise!
second_task(in=other_inputs).with_overrides( requests=Resources(mem=f"{mem_required}Gi" ) )
How to accomplish this? Do I need to use multiple @dynamic workflows so that the result returned by the first one can be passed into the second one and thus be dereferenced for use by _with_overrides()_ ?Jay Ganbat
11/27/2023, 11:52 PMresource_override = get_res_override(input)
second_task(...).with_overrides(resource_override)
Yee
Thomas Blom
11/28/2023, 1:49 PM