Nate
12/13/2024, 2:30 PMSergei
12/13/2024, 2:40 PMNate
12/13/2024, 2:42 PMSergei
12/13/2024, 2:42 PMSergei
12/13/2024, 2:49 PMBianca Hoch
12/13/2024, 6:21 PM.serve()
like so:
from prefect import flow
from prefect.logging.loggers import flow_run_logger
import time
def log_something(flow, flow_run, state):
flow_run_logger(flow_run, flow).info(f"Flow {flow.name} cancelled")
@flow(on_cancellation=[log_something])
def test_flow():
time.sleep(30)
return 42
if __name__=="__main__":
test_flow.serve(name="my-cancelled-flow")