def random_fn():
   print("Random")

@flow
def main_flow():
        prefect_flow = Flow(name="random_flow", fn=random_fn)
        deployment = Deployment.build_from_flow(
            flow=prefect_flow,
            name=random_deploy,
            version=1,
            work_queue_name="test-queue",
        )
        deployment.apply()

I'm trying to build a deployment for a flow that is created dynamically. While the deployment 'random_flow' gets created successfully, when I try to run the same, I get this error.

Flow could not be retrieved from deployment.
Traceback (most recent call last):
  File "/home/malavika/.virtualenvs/lib/python3.8/site-packages/prefect/engine.py", line 256, in retrieve_flow_then_begin_flow_run
    flow = await load_flow_from_flow_run(flow_run, client=client)
  File "/home/malavika/.virtualenvs/lib/python3.8/site-packages/prefect/client.py", line 103, in with_injected_client
    return await fn(*args, **kwargs)
  File "/home/malavika/.virtualenvs/lib/python3.8/site-packages/prefect/deployments.py", line 54, in load_flow_from_flow_run
    await storage_block.get_directory(from_path=deployment.path, local_path=".")
  File "/home/malavika/.virtualenvs/lib/python3.8/site-packages/prefect/filesystems.py", line 134, in get_directory
    shutil.copytree(from_path, local_path, dirs_exist_ok=True)
  File "/usr/lib/python3.8/shutil.py", line 555, in copytree
    with os.scandir(src) as itr:
FileNotFoundError: [Errno 2] No such file or directory: '/tmp/tmpbkxm8cdtprefect'

What can be done to link this flow to the deployment properly and get it to run through the Orion UI?

Anyone in the community that is using Prefect for CI/CD? And if so, how do you like it so far?

Hey guys, I might be missing something in v2, but in v1 I belive we can re-run just the failed tasks from a flow run, can we do the same in v2?

What are other ways to restart a flow apart from restarting in ui?

How can you stream logs to the UI from functions called in a Task that are using their own logger outside prefect? I can see those logs in the terminal, but never in the UI. I only can see logs that are defined with the

get_run_logger

Hi @Anna Geller and everyone, I wonder if there is API endpoint to check if the Agent is busy executing flows or in Idle mode? Thank you.

This message was deleted.

Hi. Should I install s3fs in addition to prefect to run the flow, because I see an error

ModuleNotFoundError: No module named 's3fs'

?

I receive an error that agent can't create a queue even if it exists, I use service account API key with role member. Should it be role with more permissions?

Prefect 2.3.1 - CI/CD: I run a freshly deployed flow at the end of my CI/CD pipeline, and would like to know whether or not the run was successful. My current idea is to poll the API for the state of the submitted run until it reaches a terminal state. Has anyone implemented a solution like this, or do you have another idea on how to solve this? 🙏

Hi. Does Prefect 2 support extras like previous version?(prefect[aws,kubernetes])

Are there any details anyone needs me to fill in? Is this the right place to be posting this? Don’t know how we like to “bump” messages here…

Hi @Chris Reuter and everyone. Is there someone that can help with answering this issues that I posted: https://github.com/anna-geller/prefect-docker-deployment/issues/1?

Hi prefect experts, I'm two days new since discovering prefect, I have a question about deployments. So If I understand correctly, unless I register a flow as a deployment, I can't trigger the flow in the orion UI Is that right? I saw docs that taught how to register a deployment (CLI or Python), but it looks like either method I can run multiple times and it will register the flow as deployments multiple times. Is there a way to create a file that simply "define" the list of deployments like flows does right now? Also how do I remove a deployment? is it through the orion UI only? Also, there seems to be no way to trigger a part of the flow (e.g. if the flow runs subflows 1,2,3,4,5 sequentially, there's no way to just run 3,4,5). Is that correct? Thanks!

Hey dear Prefectionists, I am running into weird errors with my K8s cluster workloads. The flows actually keep crashing with a 502 Bad Gateway error that mentions a Prefect Cloud URI:

prefect.exceptions.PrefectHTTPStatusError: Server error '502 Bad Gateway' for url '<https://api.prefect.cloud/api/accounts/><ACCOUNT>/workspaces/<WORKSPACE>/logs/'
For more information check: <https://httpstatuses.com/502>
Worker information:
    Approximate queue length: 0
    Pending log batch length: 1
    Pending log batch size: 360
The log worker will attempt to send these logs again in 2.0s

Is it possible that there are too many log messages sent and the Prefect Cloud API can not respond in time? Cheers!

Hello, Can't multiple users use same prefect db? I have setup postgress db and connecting with dbuser and password. User who start server first time it works for him however next user who try to start server connecting to same db there is error alembic.until.exc.CommandErro:Can't locate revision identified by 'd3....'

Hi! can a Prefect project be moved between teams? I've created a project in a personal account and recently joined a company account (with other members) but can't find info anywhere about how to make this movement (currently using Prefect 1.0)

Hello. In Prefect 1, I had a few flows stuck in Submitted for more than 1 hour, but Lazarus never did anything (although it's enabled for these flows). Is there a way to change Lazarus settings, or make sure it's working? (In the UI it's only enable/disable) I couldn't find any info in the documentation. Thank you

Do prefect 2's blocks have any sort of locking functionality? (imagine a queue-like block with some flows adding to it and others removing, how could they maintain reliability that no item gets lost?)

Hi all - is there a way to enable verbose debugging on an agent in Prefect 2, or another method to troubleshoot an agent seemingly not connecting to a workspace?

Hello! I noticed that the

createFlowRunInput

type in the GraphQL API doesn't include

labels

, is there a way to trigger a flow run with a specific label using the GraphQL API?

Hi prefect community, I am looking for a way to set up a slack alert for flows that their runtimes pass a certain expected time while the flow is still running, would appreciate your suggestions or best ways to achieve this, We are on prefect 1 and we use python for our flow runs and we already have slack alerts for failed runs but that is using flow run state changes which is not useful for this case.

Hi All, Has anyone been able to install prefect on centos7 box, I am trying to install prefect on centos7 box, but its failing saying that it needs sqlite3, I have installed latest version available for sqlite on the same centos7 box, but it doesn’t like it, if anyone have experienced such an issue before, please comments your workarounds or solutions

Hey everyone. I'm having some issues with a local agent in linux AWS-EC2. I've started it using

prefect agent start -q 'queue_name' &

(observe the '&' indicator to run it in background), but once I close my remote terminal the agent is killed. If I keep my terminal open the agent don't die. Is it a current bug, am I doing something wrong or is it the normal behavior? Thanks!

I am running prefect 2.3 inside a docker container using the following command:

prefect orion start --host 0.0.0.0

I have a reverse proxy (traefik) pointing to the container and I can access the UI at

<https://my-host:4200>

. The reverse proxy is handling ssl offload. The UI is displayed, but unable to connect to the API and I'm receiving the following message:

Can't connect to Orion API at <http://127.0.0.1:4200/api>. Check that it's accessible from your machine.

Q. Is there a way to configure the Orion UI so that it uses a relative URL

/api

? (i.e. https://my-host:4200/api)?

Good afternoon. We are having problems with Prefect appointments since 05/09/2022 that were in the queue and did not execute. I checked the processes, stopped the service and then reactivated it, but the failure persisted. As we are heading into the weekend and with impacts on some collection services, how can we resolve this glitch?

Does Prefect discard the data for old flow runs?.. maybe ones older than 14 days?.. In particular, I had a failed run from Aug 31: https://cloud.prefect.io/zesty-ai/flow-run/385b3c9b-8828-4b46-bda7-5ea32642b266 ...and today I was going to get around to poking at the bug causing it to fail, but instead I see a mostly-blank page with lots of "Uncaught TypeError: Cannot read properties of null (reading 'state')" in the JS console (see attached screenshot). In case it matters, this is for old Prefect, not 2.0.

Hi all. Having some issues trying to run a basic Prefect flow in a docker instance. Works fine on my local machine (outside docker) but then when run in a container outputs this error. Any suggestions for usage?

Hi all, Running into a bit of an odd issue around pickling of a result with a recent change to an existing flow. The return type from the task is a List[<dataclass>]. Within the object, the properties are both strings. I’ve tried re-deploying the flow, and currently in progress of upgrading from 2.2.0 to 2.3.2. Anyone experience issues around cloud pickle on returning an object from a task? Stacktrace linked in comments

Hi everyone, When I try build deployment I get this error: