@Marvin is there a way to use multiple prefect.yaml files?

@Marvin how can I persist/reuse a variable between different flow runs? The variable will be conditionally updated each time the flow runs. I am basically trying to send a slack notification only the first time a count falls below a threshold

@Marvin how would I create a prefect deployment without pip installing the prefect module?

@Marvin Why are my dask tasks not moving out of the Pending State

@Marvin I am trying to create a deployment using the prefect cli. My workpool should point to a docker image in ECR. Is the entrypoint field in the deployments section supposed to be a path in my image?

@Marvin Do you know what would cause this crash?

Crash details:
Traceback (most recent call last):
  File "/usr/local/lib/python3.10/site-packages/prefect/engine.py", line 1948, in report_task_run_crashes
    yield
  File "/usr/local/lib/python3.10/site-packages/prefect/engine.py", line 1536, in begin_task_run
    await check_api_reachable(
  File "/usr/local/lib/python3.10/site-packages/prefect/engine.py", line 2399, in check_api_reachable
    connect_error = await client.api_healthcheck()
  File "/usr/local/lib/python3.10/site-packages/prefect/client/orchestration.py", line 330, in api_healthcheck
    await self._client.get("/health")
  File "/usr/local/lib/python3.10/site-packages/httpx/_client.py", line 1757, in get
    return await self.request(
  File "/usr/local/lib/python3.10/site-packages/httpx/_client.py", line 1530, in request
    return await self.send(request, auth=auth, follow_redirects=follow_redirects)
  File "/usr/local/lib/python3.10/site-packages/prefect/client/base.py", line 251, in send
    response = await self._send_with_retry(
  File "/usr/local/lib/python3.10/site-packages/prefect/client/base.py", line 193, in _send_with_retry
    response = await request()
  File "/usr/local/lib/python3.10/site-packages/httpx/_client.py", line 1617, in send
    response = await self._send_handling_auth(
  File "/usr/local/lib/python3.10/site-packages/httpx/_client.py", line 1645, in _send_handling_auth
    response = await self._send_handling_redirects(
  File "/usr/local/lib/python3.10/site-packages/httpx/_client.py", line 1682, in _send_handling_redirects
    response = await self._send_single_request(request)
  File "/usr/local/lib/python3.10/site-packages/httpx/_client.py", line 1719, in _send_single_request
    response = await transport.handle_async_request(request)
  File "/usr/local/lib/python3.10/site-packages/httpx/_transports/default.py", line 366, in handle_async_request
    resp = await self._pool.handle_async_request(req)
  File "/usr/local/lib/python3.10/site-packages/httpcore/_async/connection_pool.py", line 262, in handle_async_request
    raise exc
  File "/usr/local/lib/python3.10/site-packages/httpcore/_async/connection_pool.py", line 245, in handle_async_request
    response = await connection.handle_async_request(request)
  File "/usr/local/lib/python3.10/site-packages/httpcore/_async/connection.py", line 76, in handle_async_request
    stream = await self._connect(request)
  File "/usr/local/lib/python3.10/site-packages/httpcore/_async/connection.py", line 124, in _connect
    stream = await self._network_backend.connect_tcp(**kwargs)
  File "/usr/local/lib/python3.10/site-packages/httpcore/_backends/auto.py", line 31, in connect_tcp
    return await self._backend.connect_tcp(
  File "/usr/local/lib/python3.10/site-packages/httpcore/_backends/anyio.py", line 114, in connect_tcp
    stream: anyio.abc.ByteStream = await anyio.connect_tcp(
  File "/usr/local/lib/python3.10/site-packages/anyio/_core/_sockets.py", line 221, in connect_tcp
    await event.wait()
  File "/usr/local/lib/python3.10/site-packages/anyio/_backends/_asyncio.py", line 1778, in wait
    if await self._event.wait():
  File "/usr/local/lib/python3.10/asyncio/locks.py", line 214, in wait
    await fut
asyncio.exceptions.CancelledError

@Marvin can one deployment have two cron settings?

@Marvin how can I pull from a docker image in GCR in my prefect.yaml deployment file

@Marvin Is there a way to exclude deployment from automation? For example, I want the automation to be triggered for all the deployments except one specific deployment.

.

@Marvin i have a task that I need to run 50 times with diferent parameters. I need to run them parallel, on a queue. I have the capacity to do 5 per time. After all of them finish, the flow should continue

@Marvin Hi! How would I define a healthCheck in the container definition when running a Prefect flow as an ECS task?

@Marvin does the Marvin AI log processing add any additional cost to my cloud account?

@Marvin how can I deploy all deployments in a prefect.yaml file?

@Marvin how do i prevent the server from crashing? prefect.exceptions.PrefectHTTPStatusError: Server error ‘500 Internal Server Error’ for url ’http://ephemeral-prefect/api/task_runs/

@Marvin what resource requests and limits should I use for a production deployment of the prefect-server helm chart?

@Marvin I am using docker-compose.yml. How can I configure my custom-logger for prefect in docker-compose file ?

@Marvin when I cancel a flow in the UI, is there a way I can gracefully terminate each task to ensure any cleanup they need to do is run before cancelling the task?

@Marvin how should I store a set of tasks that I want to reuse in multiple flows? Let's call them "core tasks". Is it a good practice to just store them in a separate python (module) file?

@Marvin I need prefect to connect to a service that uses IP whitelisting. Does Prefect Cloud have a static IP address I can whitelist?

@Marvin I want to use a prefect worker in my kube cluster. However, I need the new pods created in a specific public subnet with inbound traffic denied by firewall rules. Where would I configure that?

@Marvin $ prefect server start ModuleNotFoundError: No module named ‘prefect.server’ was working fine yesterday. no changes.

@Marvin how can I detect a sigkill sigterm signal?

@Marvin I have Prefect deployed to GCP Artifact Registry, using Prefect's

prefecthq/prefect:2-python3.10

Docker image. I take the base image, install our requirements, and copy a

flows

directory with all of our flows as Python modules into the

/opt/prefect/flows

directory in the Docker image. I use a

prefect.yaml

deployment file to deploy the flow. This all works fine and the worker shows as healthy, but when a flow is triggered, I get the error:

FileNotFoundError: [Errno 2] No such file or directory: '/opt/prefect/flows'

@Marvin Is there any chance you could show me how to write a workflow that edits all my Starfield saved games to make a millionaire? I'd like it to run daily because in previous games like Fallout 4, my saved games would sometimes get 'updated' to make me no-longer-a-millionaire, which was pretty annoying. If I'm going to use cheats to make myself rich, I'd like to stay rich, you know?

@Marvin does prefect2 UI have a view where I can filter the flow run bar graph by deployment?

@Marvin When using the

<http://marvin.ai|marvin.ai>_fn

decorator, is there any built-in way to cache the function results so I don't incur costs for duplicate inputs?

@Marvin my tasks is retrying when failing when in my development environment. when I use worker retry does not work.

@Marvin i have 1000 task runs with concurrency set to 20. it runs 20 but then there is a 30 second gap before it runs another 30. how do i prevent this gap?

@Marvin I am trying to deploy a flow run from a deployment id like this

PREFECT_API_URL=f"<https://api.prefect.cloud/api/accounts/{account_id}/workspaces/{workspace_id}>"
async def test():
    deployment_id = UUID("MY-DEPLOYMENT-ID")
    client = PrefectClient(api=PREFECT_API_URL, api_key=API_KEY)
    await client.create_flow_run_from_deployment(deployment_id=deployment_id, parameters={"connection_id": "connection_id"})


if __name__ == "__main__":
    asyncio.run(test())

But am getting the following error

Client error '403 Forbidden' for url '<https://api.prefect.cloud/api/accounts/MY-ACCOUNT-ID/workspaces/MY-WORKFLOW-ID/deployments/MY-DEPLOYMENT-ID/create_flow_run>'

Why might I get this error?