Hi, any pointer on how to use `map` with `StartFlowRun` ?

Roey Brecher

11/04/2020, 1:18 PM

Hi, any pointer on how to use

map

with

StartFlowRun

Roey Brecher

11/04/2020, 2:53 PM

My current issue is that mapped tasks are failing due to an error

Unexpected error: HTTPError('400 Client Error: Bad Request for url: <http://XXXXX:4200/graphql>')

. I’m not sure if it specifically relates to StartFlowRun. Other tasks and flows are running successfully.

Chris White

11/04/2020, 6:39 PM

Hi Roey - could you share your code? This means that the graphQL payload being sent does not match the schema, so most likely the flow run ID you are providing isn’t valid

Roey Brecher

11/05/2020, 6:54 AM

hi @Chris White here it is

Roey Brecher

11/05/2020, 6:55 AM

I’m using a FargateAgent and Prefect Server hosted on EC2

Chris White

11/06/2020, 5:02 PM

It looks like you might be providing an invalid flow name or project name when you map? Are you sure that the return values of

etl_groups

is a list of flow names and that the return value of

data_source

is a single string of the project name?

Roey Brecher

11/08/2020, 6:00 AM

in that case, how would I pass the parameters? I did try what you suggest before, but did not see how to pass parameters which should be mapped, to the Flows. i.e something like

parameters=dict(ids=ids, data_source=unmapped(data_source))

Open in Slack

Previous Next

Prefect Community

Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.