Steph Clacksman
10/12/2022, 7:21 AMimport pandas as pd
from prefect import flow
@flow
def test_flow() -> None:
df = pd.DataFrame({"ID": ["123456789", "223456789"]})
test_subflow(df)
@flow(validate_parameters=False)
def test_subflow(df: pd.DataFrame) -> None:
print(df)
if __name__ == "__main__":
test_flow()
Rob Freedy
10/12/2022, 3:21 PMSteph Clacksman
10/12/2022, 6:48 PM