Heeje Cho
02/07/2022, 5:20 PM@task
def generator(limit: int):
logger = prefect.context.get("logger")
for i in range(limit):
<http://logger.info|logger.info>(i)
yield i*i
Kevin Kho
Heeje Cho
02/07/2022, 5:22 PMKevin Kho
Heeje Cho
02/07/2022, 5:49 PM@task
def parse_gen(limit: int):
logger = prefect.context.get("logger")
empty = []
for i in generator(limit):
if i < 100:
<http://logger.info|logger.info>(i)
empty.append(i)
return empty