hello, i'm trying to do a docker deploy. It recommends serving from the root directory (but i already have a docker image there), so i am getting the error

RuntimeError: Failed to generate Dockerfile. Dockerfile already exists in the current directory.

i notice that

def generate_default_dockerfile(context: Optional[Path] = None):

optionally can take a path context, but i don't see a way to specify that from my simple flow:

if __name__ == "__main__":
    test_processing_flow.deploy(
        name="test-processor-flow",
        work_pool_name="test-docker-pool",
        image="test-processor-flow:latest",
        push=False
    )

am i missing something?

Hi, getting this error suddenly. Anyone aware of what this is? ImportError: cannot import name 'start_blocking_portal' from 'anyio' (/usr/local/lib/python3.8/dist-packages/anyio/__init__.py)

@Marvin why scheduled run can be late?

Trying my luck again, hi everyone, I am recently facing a strange problem. I have a flow (which is a subflow of another one) that runs multiple tasks. Once in a while the tasks do not even start (get stuck on pending state) and the logs of each tasks says "Crash detected! Execution was cancelled by the runtime environment." The main flow is stuck on running state and the log says: " Flow run '...' - Crash detected! Request to http://.../api/task_runs faield: PoolTimeout: . The main problem is that the tasks & subflow get stuck and even a timeout (timeout_seconds param) does not help to release the freeze... (The flow is still in running state...) I am running the flows as a k8s job on openshift and all the flows and tasks are async. Is it a known problem? Is calling an async function (as a subflow or task) could be problematic?😵‍💫

Hey Folks 👋 Lately, some of my flow runs have a "Run Count" of 2 (instead of 1). When looking at the "Results" tab I see that both runs were started pretty much at the same time. We're using k8s infra. What could be the conditions of a single flow run being started more than once? Having a flow launched twice can be quite problematic, especially when they have the same id.

Has anyone encountered the following error when using the ECS agent? Is there an easy way to increase the number of retries or backoff interval?

An error occurred (ThrottlingException) when calling the RegisterTaskDefinition operation (reached max retries: 2): Rate exceeded

@Marvin how can i trigger a flow when another flow enters completed - both flows will have the same parameters

Hey all, I’m encountering this error when I try to deploy to prefect cloud:

> Running build_docker_image step...
Step 1/10 : FROM --platform=linux/amd64 python:3.10-slim
 ---> 38ced5e623fb
Step 2/10 : WORKDIR /opt/prefect/amy-ml-server
Traceback (most recent call last):
  File "/Users/dansimons/amygda/menv/lib/python3.10/site-packages/prefect/deployments/steps/core.py", line 154, in run_steps
    step_output = await run_step(step, upstream_outputs)
  File "/Users/dansimons/amygda/menv/lib/python3.10/site-packages/prefect/deployments/steps/core.py", line 125, in run_step
    result = await from_async.call_soon_in_new_thread(
  File "/Users/dansimons/amygda/menv/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 327, in aresult
    return await asyncio.wrap_future(self.future)
  File "/Users/dansimons/amygda/menv/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 352, in _run_sync
    result = self.fn(*self.args, **self.kwargs)
  File "/Users/dansimons/amygda/menv/lib/python3.10/site-packages/prefect_docker/deployments/steps.py", line 200, in build_docker_image
    raise BuildError(event["error"])
prefect.utilities.dockerutils.BuildError: NotFound: content digest sha256:9acd79fa542a002076583004f9dd5867a308eeff29a35fb033fdbf34cf30b58e: not found

The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "/Users/dansimons/amygda/menv/lib/python3.10/site-packages/prefect/cli/_utilities.py", line 42, in wrapper
    return fn(*args, **kwargs)
  File "/Users/dansimons/amygda/menv/lib/python3.10/site-packages/prefect/utilities/asyncutils.py", line 304, in coroutine_wrapper
    return call()
  File "/Users/dansimons/amygda/menv/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 432, in __call__
    return self.result()
  File "/Users/dansimons/amygda/menv/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 318, in result
    return self.future.result(timeout=timeout)
  File "/Users/dansimons/amygda/menv/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 179, in result
    return self.__get_result()
  File "/usr/local/Cellar/python@3.10/3.10.13_1/Frameworks/Python.framework/Versions/3.10/lib/python3.10/concurrent/futures/_base.py", line 403, in __get_result
    raise self._exception
  File "/Users/dansimons/amygda/menv/lib/python3.10/site-packages/prefect/_internal/concurrency/calls.py", line 389, in _run_async
    result = await coro
  File "/Users/dansimons/amygda/menv/lib/python3.10/site-packages/prefect/cli/deploy.py", line 428, in deploy
    await _run_single_deploy(
  File "/Users/dansimons/amygda/menv/lib/python3.10/site-packages/prefect/client/utilities.py", line 100, in with_injected_client
    return await fn(*args, **kwargs)
  File "/Users/dansimons/amygda/menv/lib/python3.10/site-packages/prefect/cli/deploy.py", line 657, in _run_single_deploy
    await run_steps(build_steps, step_outputs, print_function=app.console.print)
  File "/Users/dansimons/amygda/menv/lib/python3.10/site-packages/prefect/deployments/steps/core.py", line 182, in run_steps
    raise StepExecutionError(f"Encountered error while running {fqn}") from exc
prefect.deployments.steps.core.StepExecutionError: Encountered error while running prefect_docker.deployments.steps.build_docker_image
An exception occurred.

It used to work with the exact same prefect yaml & dockerfile, not sure why it’s stopped working. Any help would be much appreciated. Thanks!

Hey Guys, I’m just getting started with prefect and I have a flow that uses custom modules. These modules are in the same directory as my flow script, and I do several

from my_module import my_function

within the flow script. Now here’s the thing; I have registered the flow and started my local agent. When I try to trigger the job to run from the prefect UI, I get the message:

Failed to load and execute flow run: FlowStorageError('An error occurred while unpickling the flow:\n ModuleNotFoundError("No module named \'extract_strings\'")\nThis may be due to a missing Python module in your current environment. Please ensure you have all required flow dependencies installed.')

The `extract_strings`function is defined in another module in the same director. Can anyone help?

@Marvin I get the following error deploying to Prefect3 prefect.exceptions.PrefectHTTPStatusError: Client error ‘422 Unprocessable Entity’ for url ‘http://localhost:4200/api/deployments/’