I m running the following flow using `create flow run` to ru

Question

I m running the following flow using `create flow run` to run a flow multiple times with different parameters Here is my code and the error i m getting

Kevin Kho · Answer

You need to register the Flow because `create flow run` hits the GraphQL API and triggers a flow run backed by Cloud

Kevin Kho · Answer

Could you move the code and traceback to the thread to keep the main channel clean

Kevin Kho · Answer

Oops sorry I meant to move the traceback but didnt copy it

Ifeanyi Okwuchi · Answer

``` import prefect from prefect import task Flow Parameter from prefect import Flow unmapped from prefect tasks prefect import create flow run from prefect executors import LocalDaskExecutor task log stdout=True def hello world user input str age input int print f hello user input You re age input today with Flow dummy flow to be run multiple times as flow user param = Parameter user input default= world age param = Parameter age input default=18 hw = hello world user param age param with Flow mapped flows executor=LocalDaskExecutor as flow parameters = dict user input= Prefect age input=21 dict user input= Marvin age input=27 dict user input= World age input=12 mapped flows = create flow run map parameters=parameters flow name=unmapped dummy flow to be run multiple times ```

Kevin Kho · Answer

Thank you

Ifeanyi Okwuchi · Answer

which of the flows should i register

Kevin Kho · Answer

The one called by `create flow run`

Kevin Kho · Answer

Well both actually for production but if you are using `flow run ` then at least the dummy one

Ifeanyi Okwuchi · Answer

I added a `flow register ` after the first flow but I still get the same error

Kevin Kho · Answer

Could you show me the new code

Ifeanyi Okwuchi · Answer

``` task log stdout=True def hello world user input str age input int print f hello user input You re age input today with Flow dummy flow to be run multiple times as flow user param = Parameter user input default= world age param = Parameter age input default=18 hw = hello world user param age param flow register with Flow mapped flows executor=LocalDaskExecutor as flow parameters = dict user input= Prefect age input=21 dict user input= Marvin age input=27 dict user input= World age input=12 mapped flows = create flow run map parameters=parameters flow name=unmapped dummy flow to be run multiple times ```

Kevin Kho · Answer

This register call won t work right You need to supply a project name to register with Prefect Cloud

Ifeanyi Okwuchi · Answer

how about when running locally

Kevin Kho · Answer

You can t use `create flow run` for local execution The code underneath hits the Prefect Cloud API Prefect 2 0 Orion will let you do this but this is a limitation in current Prefect

Ifeanyi Okwuchi · Answer

for the cloud i now have `flow register project name=PROJECT `

Kevin Kho · Answer

Yes exactly and then now you can do the create flow run

Ifeanyi Okwuchi · Answer

Now I have this warning and it doesn t seem to build a docker image ```Collecting flows Users ifeanyi Development prefect measurement ml containers prefect test prefect test test hello world py 28 UserWarning Attempting to call `flow register` during execution of flow file will lead to unexpected results flow register project name=PROJECT Processing prefect test test hello world py Building `Local` storage Registering mapped flows Done ID 778f4497 bba4 4b50 b7eb 703d189b9085 Version 1 ======================== 1 registered ========================```

Kevin Kho · Answer

That warning is fine but it s cuz you have `flow run ` in the same script The default storage will not build a Docker image for you You can check the <https docs prefect io orchestration flow config storage html|Storage> docs for more information You want to be using Docker storage

Ifeanyi Okwuchi · Answer

I have storage specified now and I don t have `flow run ` in my script ```PROJECT = seller ds production Docker storage is the most flexible for managing your dependencies storage = Docker dockerfile= Dockerfile registry url=f <http us gcr io PROJECT |us gcr io PROJECT > image name= test prefect cloud task log stdout=True def hello world user input str age input int print f hello user input You re age input today with Flow dummy flow to be run multiple times as flow user param = Parameter user input default= world age param = Parameter age input default=18 hw = hello world user param age param flow register project name=PROJECT with Flow mapped flows executor=LocalDaskExecutor as flow parameters = dict user input= Prefect age input=21 dict user input= Marvin age input=27 dict user input= World age input=12 mapped flows = create flow run map parameters=parameters flow name=unmapped dummy flow to be run multiple times ```

Kevin Kho · Answer

You have storage but it s not attached to the Flow sweat smile You can do `flow storage = storage` or `Flow storage= `

Ifeanyi Okwuchi · Answer

I had this and it still didn t build the docker image

Ifeanyi Okwuchi · Answer

oh crap

Ifeanyi Okwuchi · Answer

I have to do this for both flows

Kevin Kho · Answer

I think they need to be different images for now otherwise it will be overriden There is a way to package them in the same container though

Kevin Kho · Answer

Ifeanyi Okwuchi · Answer

So I packaged them in the same container and it works I run flows run successfully but I do not see the print statements in the logs

Ifeanyi Okwuchi · Answer

I changed from print to prefect logger still no output in the logs

Ifeanyi Okwuchi · Answer

Never mind Figured it out Thanks