Matt Koski
02/08/2024, 3:59 PMMarvin
02/08/2024, 4:00 PMNate
02/08/2024, 4:09 PMMarvin
02/08/2024, 4:09 PMNate
02/08/2024, 4:16 PM@flow
decorated function is just a python function that may or may not call other flows or tasks
that means the graph is discovered as this function runs, and you can do stuff like
In [1]: from prefect import flow, task
In [2]: @task(task_run_name="Process {i}")
...: def some_work(i: int):
...: pass
...:
In [3]: @flow
...: def all_work():
...: for i in range(10):
...: if i % 2 == 0:
...: some_work(i)
...:
In [4]: all_work()
Matt Koski
02/08/2024, 4:17 PMNate
02/08/2024, 4:21 PMmap
In [1]: from prefect import flow, task
In [2]: @task(task_run_name="Process {i}")
...: def some_work(i: int):
...: pass
...:
In [3]: @task
...: def downstream_work(nums: list[int]):
...: print(nums)
...:
In [4]: @flow(log_prints=True)
...: def all_work():
...: futures = some_work.map([i for i in range(10) if i % 2 == 0])
...: downstream_work(futures)
Matt Koski
02/08/2024, 4:25 PMMatt Koski
02/08/2024, 4:25 PMMarvin
02/08/2024, 4:26 PMMatt Koski
02/08/2024, 4:27 PMMarvin
02/08/2024, 4:27 PMNate
02/08/2024, 4:31 PMNate
02/08/2024, 4:32 PMMARVIN_OPENAI_BASE_URL
to point at your own hosted LLM via some proxy provider like litellmNate
02/08/2024, 4:32 PMNate
02/08/2024, 4:32 PMMatt Koski
02/08/2024, 4:33 PM