Example of getting the current retry count within a flow

from prefect import flow, get_run_logger
from prefect.context import get_run_context

@flow(retries=3)
def main():
    get_run_logger().warning(f"This is run {get_run_context().flow_run.run_count}")
    raise ValueError()

if __name__ == "__main__":
    main()

Nice one. Thanks.

@Emil Christensen I just tried that and got -

File "/Users/theoplatt/git/prefectcourse/pacc102.py", line 9, in try_again
    log.warning(f"This is run {get_run_context().flow_run.run_count}")
                               ^^^^^^^^^^^^^^^^^^^^^^^^^^
AttributeError: 'TaskRunContext' object has no attribute 'flow_run'

Just tried and same for me.

solved it

get_run_context().task_run.run_count

🕺

I'm doing this -

log = get_run_logger()
    log.warning(f"This is run {get_run_context().task_run.run_count}")

🕺