@Marvin using python

Deployments.build_from_flow

how do you set the

PREFECT_API_URL

?

@Marvin what does prefect save as a persitent result, is it just teh variable that a task returns in the return statement or is there more information in the pickle file that is saved?

@Marvin why does prefect put a “-0” after my task names?

@Marvin trouble-shoot this

Submission failed. RuntimeError: Timed out after 120.6319489479065s while watching task for status RUNNING

@Marvin Is it possible to keep a flow running indefinitely?

@Marvin how do you submit an entire flow async for an api to resolve?

@Marvin how to update, delete, create a block programmatically

hello all! I am taking Marvin offline for a bit to give him some rest (and some enhancements!) he'll be back soon 🙂 marvin

@Marvin hey buddy

@Marvin i have three profiles in .profiles/profiles.toml. i run a loop through each profile, set the active profile which has the PREFECT_API_URL to a workspace, and try to set up a block with each profile's configuration. unfortunately, the block are build to only one workspace. why

@Marvin Can you retry task runs only specific kinds of\ errors (i.e. only for ValueError, and only if the ValueError message matches a pattern)?

test message

@Marvin is there a way of creating a block object from querying the api such as an object mapper?

@Marvin i see this function https://github.com/PrefectHQ/prefect/blob/main/src/prefect/client/orchestration.py#L1348, namely create_deployment. it requires a flow_id. does one register a flow before a deployment?

@Marvin Is there a simple way to register every single flow in a directory? The equivalent of

prefect register <filepath>

in Prefect 1? Assume it's a bunch of

py

files with Deployments defined in Python code.

@Marvin Does Prefect 2 necessarily mean having to deal with

yaml

files?

@Marvin how can I catch errors in sub flows

@Marvin How can I delete a block by providing its slug in Python?

This message was deleted.

@Marvin How can I get a list of all deployments in Python?

@Marvin I’m getting this error:

Exception ignored in: <async_generator object add_event_loop_shutdown_callback.<locals>.on_shutdown at 0x7f3d81b374c0>
Traceback (most recent call last):
  File "/home/jon/miniconda3/envs/abraxas-env/lib/python3.10/site-packages/prefect/utilities/asyncutils.py", line 308, in on_shutdown
AttributeError: 'NoneType' object has no attribute 'pop'

Is this an internal Prefect bug?

@Marvin I'm getting this error:

Failed("Flow run encountered an exception. PrefectHTTPStatusError: Client error '429 Too Many Requests'"

What is the limit? How can I solve this?

@Marvin How do I run multiple subflows concurrently? Neither the Dask nor Concurrent taskrunners seem to let me do this.

@Marvin Demonstrate how I can configure scheduled flows using cron schedules in Prefect to skip certain periods based on a given condition. For example, if new data is extracted, I want the flow to run on a weekly basis instead of a daily basis.

Demonstrate how I can write two subflows within one flow. Each subflow should call the three same tasks I have previously defined.

@Marvin Is there any way to choose a deployment version to run?

@Marvin How do I cache a Pandas Dataframe?

@Marvin Can I customize the kubernetes tolerations for pods scheduled by Dask-Gateway when using prefect_dask with cluster_class=‘dask_gateway.GatewayCluster’ as my task_runner?

How do I update a locally hosted Prefect server, without stopping the server?

@Marvin how do I erase the cache of a flow or task?