Anyone notice deployment build time taking a lot longer than normal?

Hi! What is the equivalent to project in Prefect 2.0?

RuntimeError: The connection pool was closed while 1 HTTP requests/responses were still in-flight Using prefect cloud but I get this if I re-run my code immediately.

How we schedule flows to run at specific time in prefect 2.0? previously I have used flow.schedule()

Hey, I’m developing my first Prefect 2 flow after about a year with Prefect 1 (-: I saw that now to get Prefect’s logger I should run “get_run_logger()“. Now this works inside a flow or a task context - but what should I do when a task calls a regular python function that contains logs (logger.info for example)? For example - In prefect 1 I could write “logger = prefect.context.get(LOGGER_NAME)” at the top of the py file that contained both Prefect tasks and regular python functions (that were used from within tasks), and the logger was used by both. I tried using “get_run_logger()” at the top of the py file but got this error “There is no active flow or task run context.” Thanks @Itay vidal FYI

Another question regarding slack notifications. I saw this guide https://discourse.prefect.io/t/sending-notifications-in-cloud-1-0-using-automations-cloud-2-0-slack-webhook-blocks-and-notifications/1315 What about sending slack notifications on a local run? In Prefect 1, I added the “slack_webhook_url” to my local “/.prefect/config.toml” file - is there any solution for Prefect 2? Thanks.

Hello everyone, I want to modify some source codes, but I don't know how to view the effects after the modification. "prefect dev start" currently has problems or some bugs I think.

Hi Everyone, I am not getting how to set "name" parameter in run_deployment. Can anyone please help me here?

Hi Everyone, I'm trying out prefect2 with a self hosted orion-server and I noticed that an agent crash left over "running" flow-runs which in turn interfere or block execution for the respective workqueue if a concurrency limit is set. Is there a canonical way to deal with such a situation?

hi getting error while running >> prefect orion start failed to create process. can someone help I have created venv activated it installed prefect >> pip install prefect

Flows being stuck in running stage Hello everyone! I'm running into some problems, can you help me? I'm using Prefect 1.0. I built and coded the flows to submit more than 50 flows simultaneously. Sometimes all of these 50 flows run until the success state. But sometimes about 2 out of 50 are stuck at running state (whether all tasks are finished, or there are tasks left). It kept being "*running*" forever until I CANCEL it. I don't know where to find and fix them, as they kept turning into zombies like that. Can I ask where the problem might be (code, my Prefect agent, conflicts,...?) so that I can check it and try to fix it? Thank you so muchhhhh

Hey guys there a reason for signals (

FAIL

,

PrefectStateSignal

,

PrefectSignal

) inherit from

BaseException

instead of

Exception

?

Hi there, Does anyone use loguru on Prefect 2.0? As the v2.0 does not have way to set a Global logger I was trying to add loguru as an extra logger to prefect. I’ve tried:

prefect config set PREFECT_LOGGING_EXTRA_LOGGERS="rootlogger,loguru,root,root logger"

But it did not worked. Any tips?

In Prefect 1.0, how can we determine what user cancelled a flow run?

Hey, We are developing a flow where a lot of JSON records get queried (in a Task). To save on memory resources, I've configured Result Persistence on the Task, but I'm now noticing a build up of memory usage of a serializer object. When are results serialized and when is this memory released?

hi guys, I have this error in Prefect Agent

ERROR   | prefect.agent - Failed to submit flow run 'xxxx' to infrastructure.

how can I investigate the details?

Hi all! Thanks for a great tool and community. Summary: I'm trying to get a deployment up and running in Azure Container Instances but Prefect Cloud keeps stopping my container after a few minutes. Do you have any ideas of what could be happening? I'm running a flow using deployments in Azure Container Instances. I manage to successfully trigger the job and the container starts running and processing the tasks correctly. After a while, for no apparent reason, the agent receives the instruction from prefect (running on Cloud) to delete the container:

16:44:27.874 | INFO    | prefect.infrastructure.container-instance-job - AzureContainerInstanceJob 'sftp-to-blob-ingestion': Preparing to run command '/opt/prefect/entrypoint.sh python -m prefect.engine' in container 'a53fd966-c635-4605-a8ab-4a3f487a7463' (prefecthq/prefect:2.6.7-python3.9)...
16:44:27.875 | INFO    | prefect.infrastructure.container-instance-job - AzureContainerInstanceJob 'sftp-to-blob-ingestion': Waiting for container creation...
16:45:37.024 | INFO    | prefect.infrastructure.container-instance-job - AzureContainerInstanceJob 'sftp-to-blob-ingestion': Running command...
16:45:37.025 | INFO    | prefect.agent - Completed submission of flow run '6bb0fc44-197e-4bfd-846e-877f5dbbf0b8'
16:48:43.454 | INFO    | prefect.infrastructure.container-instance-job - AzureContainerInstanceJob 'sftp-to-blob-ingestion': Completed command run.
16:48:43.455 | INFO    | prefect.infrastructure.container-instance-job - AzureContainerInstanceJob 'sftp-to-blob-ingestion': Deleting container...

In the meantime the Orion UI gets frozen in 'running' state and there are no log lines indicating any error or crash.

Can some one from @Prefect community help?Please https://prefect-community.slack.com/archives/CL09KU1K7/p1668791166095479

Hi all, I started testing my upgrade to 2.0 and downloaded the new version. I need to deploy an update to my 1.0 version which is still in prod and now I am getting an error with my tasks. How do I revert to the Prefect 1.0 version?

hey everyone! 👋🏻 I am running Prefect Orion and the agents on a Kubernetes cluster and I was looking for a way to define Blocks as code manner. Deployment of Prefect itself with GitOps approach is super easy (nice helm chart!) but I do not want to define my Blocks via UI, I want them to persist and be consistent every time I reinstall Prefect..is there a way to achieve that? Thank you!

Does anyone know why a mapped task might indicate "Ready to proceed with mapping" but it never proceeds? It works fine with LocalExecutor but not with DaskExecutor (via FargateCluster). I'm really frustrated because I know I've encountered and solved this exact issue before...

Hello so I have a state handler that checks for failed state and send an email. However, I want to add retry logic to this handler (because the handler is not a task) if the email fails, is there anyway to do this using prefect? This is for prefect v1.

Hello, I need to create an API key and URL for the prefect agent. To confirm, can a service account only be created on the paid tier?

Hi all, deploying a Prefect pipeline that uses dbt models- I upgraded to their new 2.0 version and then had to downgrade again to run our production pipeline (my mistake- I needed to create a venv). I changed my DockerFile to use this image from Prefect-

FROM prefecthq/prefect:1.4.0-python3.9

and now I get this error when running

dbt deps

Hello, I am running into an issue in the docker build step. Error " Step 4/4 : COPY flows/ flows/ 129 COPY failed: file not found in build context or excluded by .dockerignore: stat flows/: file does not exist. Using the docker image from this repo. cc: @Taylor Curran

Hi, I'm running into, what is probably a very simple issue with docker networking. Setup: • Orion Server (running locally: 127.0.0.1:4200) • Prefect Agent (running locally) • Airbyte Server (running locally: 127.0.0.1:8000) • Docker Infra Block - Docker running locally The agent can see the server. I can create and apply a deployment. On starting the flow: • The agent kicks off. • The agent creates the docker image. • The agent applies any pip requirements from block env setting. • It then fails with

ConnectionRefusedError: [Errno 111] Connect call failed ('127.0.0.1', 4200)

I'm assuming the flow running in the docker container cannot see the orion server on port 4200, however, I'm not sure what to do to fix that. No doubt the next failure will be accessing the Airbyte server, but I'm not there yet. Any help is much appreciated.

Hey Prefect - I get a heap of these errors now days with 2.0: 🧵

Prefect 2.0: The Prefect Cloud - Flow Run - Date Range , if the range include today, it won't really shows any flow runs today........i think the backend data base may use the 0 am of today. Anyone having the same issue here?

Hi folks I'm trying to setup my Prefect v2 flows to run in `KubernetesJob`'s but I'm having trouble figuring out the best way to setup my storage block. In my deployments, I create a docker image with all my flow code and corresponding dependencies. I wish I could use something like the

DockerContainer

storage block to my deployment indicating that it should just pull my docker image from AWS ECR and run the flow. However, as far as I understand, the

DockerContainer

block is also an infrastructure block and is meant to run the image against docker directly on a machine - i.e., NOT in a

KubernetesJob

. This means that so far, I've been relegated to using the

S3

storage block which pushes my flow code to S3, only to pull it back to my docker image at flow run time (when the image already contains all the code it needs to run). This feels wrong so I'm sure I must be missing something here. How do I configure

KubernetesJob

to just pull a docker image and not rely on any additional storage block like S3? PS: so far, I'm really enjoying how quickly I'm getting up to speed on prefect v2. Despite of kinks like this, I'm really enjoying the development experience.

Hello Team, am new to prefect2. Am working on migrating flow from prefect1 to prefect2.