William Jackson
03/30/2026, 8:15 PM@flowMarvin
03/30/2026, 8:15 PMMarvin
03/30/2026, 8:16 PMfrom prefect import flow, get_run_logger
@flow(retries=2, retry_delay_seconds=10, log_prints=True)
def main(x: int = 1) -> int:
logger = get_run_logger()
<http://logger.info|logger.info>("Starting flow-only run")
y = x * 2 # all your logic here
if y % 3 == 0:
logger.warning("Multiple of 3!")
return y
if __name__ == "__main__":
main()
If you later want granular retries, caching, or parallelism for specific steps, you can refactor those pieces into `@task`s while keeping the rest of the logic in the flow.