Deceivious
07/27/2023, 8:14 AMimport prefect
from prefect import flow
from prefect.deployments.deployments import Deployment
@flow
def success():
prefect.get_run_logger().info("a")
@flow
def fail():
prefect.get_run_logger().info("b")
@flow
def main_flow():
prefect.get_run_logger().info("c")
success()
fail()
if __name__ == "__main__":
Deployment.build_from_flow(flow=main_flow, name="test_flow", apply=True)
Christopher Boyd
07/28/2023, 12:51 PMDeceivious
07/28/2023, 12:53 PMThe persist_result option defaults to a null value, which will automatically enable persistence if it is needed for a Prefect feature used by the flow or task.
Also according to docsChristopher Boyd
07/28/2023, 12:55 PMDeceivious
07/28/2023, 12:57 PMChristopher Boyd
07/28/2023, 12:57 PMDeceivious
07/28/2023, 12:59 PMChristopher Boyd
07/28/2023, 1:00 PMDeceivious
07/28/2023, 1:01 PMChristopher Boyd
07/28/2023, 1:02 PMDeceivious
07/28/2023, 1:03 PMNone
3. Id say it would be weird if I had to allocate a shared remote storage infrastructure to store those `None`s in esp. as the results are not being used at all. The status of the subflows are in Prefect database.Christopher Boyd
07/31/2023, 12:23 PMDeceivious
07/31/2023, 1:05 PM