Heya! Hopefully this is an easy thing to do: I hav...
# ask-communityj
jpuris
12/18/2023, 3:39 PMHeya! Hopefully this is an easy thing to do: I have a flow that calls bunch of subflows. Each subflow processes an "entity" e.g. product, discount etc.
How can I give these subflows an appropriate name?
Right now it is a dictionary generated pairs e.g.
Copy code
currently => desired
---
smoky-moose => product
giga-locus => discount✅ 1
jpuris
12/18/2023, 3:43 PMThe subflows as of right now are called in a loop in the main flow
Copy code
for entity in entities:
<http://logger.info|logger.info>(f"Processing entity '{entity}'")
process_entity(
entity=entity,
) Copy code
@flow(
cache_result_in_memory=False,
task_runner=SequentialTaskRunner(),
)
def process_entity(
entity,
) -> None:
logger = get_run_logger()
...j
Jake Kaplan
12/18/2023, 3:44 PMhey, you can use
@flow(flow_run_name=...)Jake Kaplan
12/18/2023, 3:45 PMIt can be provided as a string template with the flow's parameters as variables or it can also be provided as a function that returns a string
Jake Kaplan
12/18/2023, 3:46 PMe.x. for the string templating:
Copy code
from prefect import flow
@flow(flow_run_name="subflow1-{param1}")
def subflow1(param1):
print("Hello from a subflow!")
@flow(log_prints=True)
def my_flow():
print("Hello from a flow!")
subflow1("my-very-first-param")
if __name__ == '__main__':
my_flow()🙌 1
Jake Kaplan
12/18/2023, 3:47 PMj
jpuris
12/18/2023, 3:49 PMBrilliant! I did not know you can inject the function args like that.
Thank you @Jake Kaplan!
🙌 2
t
Tim Galvin
12/19/2023, 5:28 AMNow that is cool! I didn't know either!
5 Views