Marcin Grzybowski
06/01/2022, 2:00 PMAnna Geller
06/01/2022, 2:02 PMMarcin Grzybowski
06/01/2022, 2:08 PMAnna Geller
06/01/2022, 2:21 PMfrom prefect import flow
@flow
def subflow_first(x: int = 42) -> int:
print("I am a first subflow!")
return x
@flow
def second_subflow(x) -> int:
print("I am a second subflow!")
return x
@flow
def parent_flow():
data = subflow_first().result()
second_subflow(data)
if __name__ == "__main__":
parent_flow()
Marcin Grzybowski
06/01/2022, 3:07 PMAnna Geller
06/01/2022, 7:55 PMprefect version
?Marcin Grzybowski
06/01/2022, 7:56 PM(prefect2.0) marcin@WSW-5M78J5J:/mnt/h/projects/prefect2.0$ prefect version
Version: 2.0b5
API version: 0.3.1
Python version: 3.9.5
Git commit: 7b27c7cf
Built: Tue, May 17, 2022 4:54 PM
OS/Arch: linux/x86_64
Profile: default
Server type: ephemeral
Server:
Database: sqlite
SQLite version: 3.31.1
Anna Geller
06/01/2022, 8:09 PMMarvin
06/01/2022, 8:11 PM