Matthew Scanlon
05/30/2023, 1:18 PMNate
06/05/2023, 8:14 PMIn [14]: class Anything(BaseModel):
...: foo: str
...:
In [15]: @flow
...: def emits_anything() -> Anything:
...: return Anything(foo="something")
...:
In [16]: @flow(log_prints=True)
...: def accepts_anything(anything: Anything):
...: print(anything)
...:
In [17]: anything = emits_anything()
15:12:33.619 | INFO | prefect.engine - Created flow run 'quartz-iguana' for flow 'emits-anything'
15:12:34.441 | INFO | Flow run 'quartz-iguana' - Finished in state Completed()
In [18]: accepts_anything(anything)
15:12:44.867 | INFO | prefect.engine - Created flow run 'magnetic-copperhead' for flow 'accepts-anything'
15:12:45.372 | INFO | Flow run 'magnetic-copperhead' - foo='something'
15:12:45.495 | INFO | Flow run 'magnetic-copperhead' - Finished in state Completed()
Nate
06/05/2023, 8:15 PMMatthew Scanlon
06/06/2023, 1:07 PM