Calvin Leather
11/21/2022, 8:16 PM@task
def test_task(input: int) -> int:
import time
time.sleep(600)
return input + 1
@dynamic
def test_dynamic(list_of_ints: List[int]) -> List[int]:
results = []
for integer in list_of_ints:
result = test_task(input=integer).with_overrides(requests=Resources(cpu=f"{integer}", mem=f"{integer}Gi"))
results.append(result)
return results
Yee
11/21/2022, 11:09 PMCalvin Leather
11/21/2022, 11:21 PMYee
11/21/2022, 11:22 PMKetan (kumare3)
11/22/2022, 2:22 AM