I am getting this error while executing a flow via Cloud Pre

Question

I am getting this error while executing a flow via Cloud Prefect 2 0 RuntimeError This portal is not running Any clue what is going wrong The same flow was working fine before I use Cloud Prefect 2 0 Actually it finishes all my flows and tasks successfully and at the end it crashes and it happens to all my existing flows line 1512 in propose state raise prefect exceptions Abort response details reason prefect exceptions Abort This run has already terminated

Michael Adkins · Answer

Can you share the full traceback and a small example flow that this occurs for The output of `prefect version` would be useful as well

Xavier Babu · Answer

prefect orion 2 03b

Xavier Babu · Answer

20 25 31 787 | INFO | prefect engine Created flow run wealthy poodle for flow Parent Flow1 20 25 31 787 | INFO | Flow run wealthy poodle Using task runner ConcurrentTaskRunner I m the parent flow 20 25 32 167 | INFO | Flow run wealthy poodle Created subflow run lavender peacock for flow Sub Flow3 I m the subflow 20 25 32 455 | INFO | Flow run lavender peacock Finished in state Completed None 20 25 32 741 | ERROR | Flow run wealthy poodle Crash detected Execution was interrupted by an unexpected exception Traceback most recent call last File localpart0 aop shared WAVES workflows flow1 py line 27 in lt module gt parent flow1 File localpart0 aop shared WAVES prefect2 lib python3 10 site packages prefect flows py line 314 in call return enter flow run engine from flow call self parameters File localpart0 aop shared WAVES prefect2 lib python3 10 site packages prefect engine py line 110 in enter flow run engine from flow call return anyio run begin run File localpart0 aop shared WAVES prefect2 lib python3 10 site packages anyio core eventloop py line 56 in run return asynclib run func args backend options File localpart0 aop shared WAVES prefect2 lib python3 10 site packages anyio backends asyncio py line 233 in run return native run wrapper debug=debug File localpart0 aop shared WAVES prefect2 lib python3 10 asyncio runners py line 44 in run return loop run until complete main File localpart0 aop shared WAVES prefect2 lib python3 10 asyncio base events py line 641 in run until complete return future result File localpart0 aop shared WAVES prefect2 lib python3 10 site packages anyio backends asyncio py line 228 in wrapper return await func args File localpart0 aop shared WAVES prefect2 lib python3 10 site packages prefect client py line 82 in with injected client return await fn args kwargs File localpart0 aop shared WAVES prefect2 lib python3 10 site packages prefect engine py line 175 in create then begin flow run return await begin flow run File localpart0 aop shared WAVES prefect2 lib python3 10 site packages prefect engine py line 283 in begin flow run await client propose state File localpart0 aop shared WAVES prefect2 lib python3 10 site packages prefect client py line 1512 in propose state raise prefect exceptions Abort response details reason prefect exceptions Abort This run has already terminated

Xavier Babu · Answer

Code is from prefect import flow from prefect import task flow from prefect task runners import DaskTaskRunner from prefect deployments import DeploymentSpec from prefect flow runners import SubprocessFlowRunner from prefect tasks import task input hash from datetime import timedelta from prefect import get run logger from prefect orion schemas schedules import RRuleSchedule from dateutil rrule import rrule MINUTELY DAILY MO TU WE TH FR import pendulum from prefect orion schemas schedules import IntervalSchedule from datetime import timedelta flow name= Parent Flow1 def parent flow1 print I m the parent flow sub flow flow name= Sub Flow3 def sub flow print I m the subflow if name == main parent flow1

Xavier Babu · Answer

It is a very simple code

Xavier Babu · Answer

The main error at the end of executing the flow completely is Crash detected Execution was interrupted by an unexpected exception

Xavier Babu · Answer

upgraded to 2 0b3 and it solved the problem

Michael Adkins · Answer

This seems like an error that would be raise don 2 0b2

Michael Adkins · Answer

Yeah we were setting the final flow run state twice in 2 0b2 which shouldn t be allowed but a separate bug allowed it to happen We patched the server to ban the behavior which means 2 0b2 and older are not supported with Cloud anymore

Xavier Babu · Answer

Thanks Michael

Michael Adkins · Answer

< Zach Angell> perhaps once we have a better API version mismatch error bumping the version in a case like this would be the best outcome so the error tells them to upgrade slightly smiling face

Michael Adkins · Answer

Glad it s worked out for you slightly smiling face

Xavier Babu · Answer

How to cleanup existing flows and tasks in Cloud 2 0

Xavier Babu · Answer

There is no reset DB option

Michael Adkins · Answer

You d probably need to delete and recreate your workspace

Xavier Babu · Answer

oh man ok

Xavier Babu · Answer

Any doc or guidance or tutorial to make a REST API call to Cloud Prefect 2 0 please

Michael Adkins · Answer

With the Python client Prefect provides or with another tool

Xavier Babu · Answer

We have a Web UI which calls Prefect REST APIs to create a flow or schedule it

Xavier Babu · Answer

We use Create Flow Run Deploy APIs

Michael Adkins · Answer

I see so if you run `prefect config view` you should see the API url you need to hit as a well as your current API key

Xavier Babu · Answer

So far we used with the prefect deployed locally in our server Since today I configured with Cloud 2 0 I would like to know how to call it

Michael Adkins · Answer

You need to provide the API key in a header e g `httpx settings headers setdefault Authorization f Bearer api key `

Xavier Babu · Answer

I don t need to create bearer token before call the API via that URL

Michael Adkins · Answer

You need the token presumably you have one locally that you can use

Michael Adkins · Answer

You could create a separate one too

Xavier Babu · Answer

Example would help Thanks Michael

Michael Adkins · Answer

We don t have any examples published yet

Michael Adkins · Answer

You can see the REST documentation at <https orion docs prefect io api ref rest api >

Michael Adkins · Answer

These include examples for each endpoint you ll just need to hit the API url that includes you account workspace handle and set the key in the header

Xavier Babu · Answer

it worked Thanks