Channels
announcements
ask-marvin
best-practices-coordination-plane
data-ecosystem
data-tricks-and-tips
events
find-a-prefect-job
geo-bay-area
geo-berlin
geo-boston
geo-chicago
geo-colorado
geo-dc
geo-israel
geo-japan
geo-london
geo-nyc
geo-seattle
geo-texas
gratitude
introductions
marvin-in-the-wild
pacc-clearcover-june-12-2023
pacc-may-31-2023
ppcc-may-16-2023
prefect-ai
prefect-aws
prefect-azure
prefect-cloud
prefect-community
prefect-contributors
prefect-dbt
prefect-docker
prefect-gcp
prefect-getting-started
prefect-integrations
prefect-kubernetes
prefect-recipes
prefect-server
prefect-ui
random
show-us-what-you-got
Title
h
Horatiu Bota
05/31/2022, 10:20 AMhi community! is there a way to look-up a flow's id using the flow name/project name via the client? this suggests you can via the cli
a
Anna Geller
05/31/2022, 10:38 AMwhat are you trying to do?
h
Horatiu Bota
05/31/2022, 10:39 AMhi Anna! i'm trying to start multiple runs for a flow that's been previously registered
(i.e., runs with different parameters)
a
Anna Geller
05/31/2022, 10:40 AMI can point you to some resources:
ā¢ https://discourse.prefect.io/t/how-can-i-get-the-flow-id-programmatically/462
ā¢ https://discourse.prefect.io/t/how-to-get-a-flow-id-given-a-project-name-and-flow-name-using-a-graphql-api-query/783
ā¢ https://discourse.prefect.io/t/how-to-get-the-latest-flow-version-flow-id-within-a-project-using-graphql-query/881
but to start multiple runs you don't necessarily have to know the flow ID
usually, you only need to know the flow name and project name
so while the above links answer your direct questions, I think this one will address your actual problem: https://discourse.prefect.io/t/how-to-map-over-flows-with-various-parameter-values/365
h
Horatiu Bota
05/31/2022, 10:43 AMthank you! i'm using
create_flow_runa
Anna Geller
05/31/2022, 10:43 AMcreate_flow_run.map(
flow_name=unmapped("yourflow"),
project_name=unmapped("yourproject"),
parameters=your_list_of_dicts
)h
Horatiu Bota
05/31/2022, 10:44 AMoh, nice, this is what i need! š
š 1
thank you!
š 1
is this for orion?
a
Anna Geller
05/31/2022, 10:45 AMno, for Prefect 1.0
for Orion, you could do a for loop with subflows
h
Horatiu Bota
05/31/2022, 10:46 AMhm, the method signature in client.py seems different:
def create_flow_run(
self,
flow_id: str = None,
context: dict = None,
parameters: dict = None,
run_config: RunConfig = None,
labels: List[str] = None,
scheduled_start_time: datetime.datetime = None,
idempotency_key: str = None,
run_name: str = None,
version_group_id: str = None,
) -> str:should i be importing it from somewhere else? i'm using prefect 1.1
a
Anna Geller
05/31/2022, 10:47 AM*prefect.tasks.prefect.flow_run.create_flow_run*(flow_id=None, flow_name=None, project_name="", parameters=None, context=None, labels=None, run_name=None, run_config=None, scheduled_start_time=None, idempotency_key=None)
both id and name are valid
h
Horatiu Bota
05/31/2022, 10:48 AMah, ok, i was calling the method on a prefect client
thank you again!
š 1