Hi, I’ve set some task concurrency limits using a tag. How can I check in the GUI that this concurrency limit was actually enforced?

Hi, under which circumstances could I get this error:

State data is missing. Typically, this occurs when result persistence is disabled and the state has been retrieved from the API.

. Result persistence is indeed disabled, but I do not understand what/why "state" would be retrieved from the API. My flow returns the result of a run_deployment call (with an await).

Hey Prefect Team! What is the roadmap for the prefect terraform provider? there is channel for it?

Hi all! I am just getting started setting up prefect in an enterprise setting and have a pretty simple question that I can’t seem to find an answer to: is it still free and legal to use prefect in an enterprise setting? The pricing breakdown explains the personal use option, but is that only for prefect cloud? Can I host prefect myself and take advantage of all its functionality?

Hi - how does one get access to paid support on an Organization plan?

Hi @Prefect I've deployed my flow into an agent, but when executing the deployment on the UI, it looks like it keeps throwing this error (grabbed from the console of the agent that flow is running from). It looks like the process is trying to access the logging flow at the same time because the tasks within the flow are being executed concurrently. I've also attached the flow and tasks for reference below. Not sure if this is a bug, or something else. Error:

--- Logging error ---
Traceback (most recent call last):
  File "\\v-tm-qeq-05\Prefect\lib\logging\handlers.py", line 70, in emit
    self.doRollover()
  File "\\v-tm-qeq-05\Prefect\lib\logging\handlers.py", line 171, in doRollover
    self.rotate(self.baseFilename, dfn)
  File "\\v-tm-qeq-05\Prefect\lib\logging\handlers.py", line 111, in rotate
    os.rename(source, dest)
PermissionError: [WinError 32] The process cannot access the file because it is being used by another process: 'C:\\Users\\qtask\\prefect.log' -> 'C:\\Users\\qtask\\prefect.log.1'
Call stack:
  File "\\v-tm-qeq-05\Prefect\lib\runpy.py", line 194, in _run_module_as_main
    return _run_code(code, main_globals, None,
  File "\\v-tm-qeq-05\Prefect\lib\runpy.py", line 87, in _run_code
    exec(code, run_globals)
  File "\\v-tm-qeq-05\Prefect\Scripts\prefect.exe\__main__.py", line 7, in <module>
    sys.exit(app())
  File "\\v-tm-qeq-05\Prefect\lib\site-packages\typer\main.py", line 311, in __call__
    return get_command(self)(*args, **kwargs)
  File "\\v-tm-qeq-05\Prefect\lib\site-packages\click\core.py", line 1130, in __call__
    return self.main(*args, **kwargs)
  File "\\v-tm-qeq-05\Prefect\lib\site-packages\typer\core.py", line 778, in main
    return _main(
  File "\\v-tm-qeq-05\Prefect\lib\site-packages\typer\core.py", line 216, in _main
    rv = self.invoke(ctx)
  File "\\v-tm-qeq-05\Prefect\lib\site-packages\click\core.py", line 1657, in invoke
    return _process_result(sub_ctx.command.invoke(sub_ctx))
  File "\\v-tm-qeq-05\Prefect\lib\site-packages\click\core.py", line 1657, in invoke
    return _process_result(sub_ctx.command.invoke(sub_ctx))
  File "\\v-tm-qeq-05\Prefect\lib\site-packages\click\core.py", line 1404, in invoke
    return ctx.invoke(self.callback, **ctx.params)
  File "\\v-tm-qeq-05\Prefect\lib\site-packages\click\core.py", line 760, in invoke
    return __callback(*args, **kwargs)
  File "\\v-tm-qeq-05\Prefect\lib\site-packages\typer\main.py", line 683, in wrapper
    return callback(**use_params)  # type: ignore
  File "\\v-tm-qeq-05\Prefect\lib\site-packages\prefect\cli\_utilities.py", line 41, in wrapper
    return fn(*args, **kwargs)
  File "\\v-tm-qeq-05\Prefect\lib\site-packages\prefect\utilities\asyncutils.py", line 260, in coroutine_wrapper
    return call()
  File "\\v-tm-qeq-05\Prefect\lib\site-packages\prefect\_internal\concurrency\calls.py", line 234, in __call__
    coro = self.run()
  File "\\v-tm-qeq-05\Prefect\lib\site-packages\prefect\_internal\concurrency\calls.py", line 163, in run
    return self.context.run(asyncio.run, self._run_async(coro))
  File "\\v-tm-qeq-05\Prefect\lib\asyncio\runners.py", line 44, in run
    return loop.run_until_complete(main)
  File "\\v-tm-qeq-05\Prefect\lib\asyncio\base_events.py", line 603, in run_until_complete
    self.run_forever()
  File "\\v-tm-qeq-05\Prefect\lib\asyncio\windows_events.py", line 316, in run_forever
    super().run_forever()
  File "\\v-tm-qeq-05\Prefect\lib\asyncio\base_events.py", line 570, in run_forever
    self._run_once()
  File "\\v-tm-qeq-05\Prefect\lib\asyncio\base_events.py", line 1859, in _run_once
    handle._run()
  File "\\v-tm-qeq-05\Prefect\lib\asyncio\events.py", line 81, in _run
    self._context.run(self._callback, *self._args)
  File "\\v-tm-qeq-05\Prefect\lib\site-packages\prefect\agent.py", line 490, in _submit_run_and_capture_errors
    result = await infrastructure.run(task_status=task_status)
  File "\\v-tm-qeq-05\Prefect\lib\site-packages\prefect\infrastructure\process.py", line 163, in run
    self.logger.error(
Message: "Process 'wandering-panda' exited with status code: 3221225477"
Arguments: ()
10:21:22.906 | ERROR   | prefect.infrastructure.process - Process 'wandering-panda' exited with status code: 3221225477
10:21:22.969 | INFO    | prefect.agent - Reported flow run '7c18182d-631b-428a-bf7e-d0b631d86dd9' as crashed: Flow run infrastructure exited with non-zero status code 3221225477.

Hey team - we are experiencing intermittent failures when trying to connect to our servers from a fargate ECS flow run. We have a couple of scenarios, one being a flow which kicks off 10 subflows. Daily, 1 to 2 of the 10 subflows fail with connection issues to our database. On these subflows, reruns/restart do not solve the issue which is why we believe it may be a prefect issue rather than a security group or database issue. Are there any settings we could check or verify to ensure the tasks have the proper configuration (VPC, security groups, maybe max number of concurrent tasks or a prefect timeout)

Can you pass in infra overrides on the flow run when you call it?

Anybody run into this issue? I'm seeing it on my AWS EC2 instance where I'm running an agent:

httpx.LocalProtocolError: Invalid input ConnectionInputs.SEND_HEADERS in state ConnectionState.CLOSED

Hi all! I set up a self hosted prefect server in kubernetes, and while I am able to view the UI/ingress interface in my browser on my local dev environment, I am unable to connect to the API in my Python scripts. I followed the docs and ran the “prefect config set PREFECT_API_URL=“<my-ingress-url>”” but when I run my Python scripts I still get a “Failed to reach API error.” Has anyone run into this before?

Hi, what do I pass to

LogFilterLevel()

to only get errors?

hello guys. I need help here. so, i have a simple flow that do extract and load data. in the extract step i get a result from cx_oracle basiclly ~70k row and 77 columns. the result is passed to load task (again using cx_oracle). i think the process inside task is success without problem (in prefect and i try a basic python function call on notebook). but the problem is in prefect there is a gap between the end of extract task to the start of load task (will provide an image), the gap time is relativelly big, sometimes even longer than the extract task process. is there some problem in passing data between task or what? the flow running on kubernetes-job and i use on premise prefect server and agent (all in same cluster)

Over the last two weeks we often see flows stuck again in a Running state, after a k8s job is terminated unexpectedly. This used to be a problem some time ago but has been stable for a while (where Prefect would mark the flow run as Crashed). Has anything changed there?

Hey team I was wondering what happened to projects in the latest version of prefect or is this still a beta feature?

Hello, I'm trying to run a workload on ECS using this . Server and Agent both run on ECS and talk to each other, but the task that is spun by the Agent runs for a while then times out. I guess it's because this task cannot reach the Server because it was spun outside of the security group associated with the Agent. In the video, we can briefly see that Taylor's ECSTask has a task_customizations parameter mentioning a security group. I tried to set the same parameter in my ECS infra block using the Agent security group id, but the run crashes without logs and without submitting to ECS. Am I on the right track on this one?

When scheduling a deployment, is there a way to specify values for parameters? So far it looks like setting an override value for a parameter sets it for all flow runs (not just for the scheduled flow runs.)

Hello, I am starting at prefect 2 I wonder something. • I have built some storage block for s3 in a bucket at my org. • also built a deployment.yaml file for my flow using that s3 storage. • I saw that whenever I run the deployment, it copies all the root code from my PC to s3 bucket So my question is, should I create a bucket folder for each flow? Or what is the best practice here?

I have a prefect server and 2 prefect agents up and running. Is there a way to run the subflows/tasks of a single main flow in multiple agents?

Hello! Little question about Prefect Cloud and flows’ local development. I’ve got several colleagues writing flows in their local environment. It means a lot of write-run-fix loops. And every single run is collected by Prefect Cloud and displayed in UI. Everyone has an active Prefect profile in their environment. We need to have it activated because we rely on custom Blocks, deployed into Prefect Cloud + shared credentials in blocks like GCPCredentials or GCPSecret. So we can’t just initialize Prefect - we need to have everyone connected to Prefect Cloud. And the question is: can we somehow switch off sending information about Flow’s run to the server, depending on some local variable, but still be able to access Blocks in the Cloud? So local development will not turn Cloud UI into a mess.

Out of curiosity, is there a "Wait for user" task at all? Im thinking like how in other pipelines you can wait for the user to hit "go" or similar if some checks need to be done before proceeding with a transaction/deployment/rollout, etc

Hey folks 👋 If you need need to run

prefect deploy

using Docker deployment model in an CI/CD environment where Python is not available (like my Jenkins CI/CD environment), consider running

prefect deploy

inside a Docker container itself! Doing this, Prefect will still be able to build the Docker image for your flow. Just make sure that the Docker container where you run

prefect deploy

has access to the Docker Engine. One way to do this, is by passing the following volume (tested on Mac):

-v /var/run/docker.sock:/var/run/docker.sock

Sharing just in case someone else need it! 🙌

Hi there, I noticed that link artifacts are being created with

type = "markdown"

rather than

type = "link"

. Just wanted to double check there isn't an intentional reason for this? Looks like it would just be a one line change to fix if it is a bug (https://github.com/PrefectHQ/prefect/blob/f32b9c35e8ae8af5d74754663fb2d613a44c4d3d/src/prefect/artifacts.py#L94). Thanks!

I am trying to use ECSTask infra block with predefined

task_definition_arn

are there any examples for that?

Prefect V1 question - are RRule Clocks not supported in Prefect Cloud? They are documented but when I use one my schedule says "Unrecognized Clock"

This message contains interactive elements.

Hello, does anyone know who to contact to delete my prefect.io account? I have reached out here, on the forum, multiple emails. No one responds?

What’s the recommended way of launching a flow that branches out to multiple nodes on kubernetes?

Hi, our Prefect jobs are stuck in a "Running" state lately after a pod eviction in k8s. This used to work properly where the flow run would get marked as "Crashed" in those situations. Now, with the flow run stuck forever, it blocks our entire process. Looks like a regression, can anyone help out?

Hi, I started using Prefect to build a data extraction pipeline, I have currently a problem, for each flow run prefect creates some files under the folder ".prefect" I didn't notice it before until I saw that all my storage was full . I added to my flows, but still have the creation of those files, can someone advice on this?

persist_result=False,

Hi, in a flow with subflows, if a subflow fails at a task and I retry the parent flow. the parent flow creates a new subflow run and starts all the tasks in it(completed or otherwise). I was expecting it to run the same subflow and continue with the failed task. Am I not understanding the logic or am I missing a settings somewhere?