We're looking to transition from Prefect 1.0 to 2.0 when it's generally available. We run on our own servers instead of using Prefect Cloud. Despite being adorable, we opted to not use the default flow run names (e.g. delightful-marten, portable-scallop, strong-muskrat) and have our flows rename themselves with names that describe properties of their data. In Prefect 1.0, we used the

RenameFlowRun

task. How do we do the same thing in Prefect 2.0? I don't see a similar task but maybe I just missed it. Thanks for the help!

We are on

1.1.0

. I cancelled a running flow through the UI; it was deep in the middle of running a series of mapped tasks. Turns out it continued to run for 6 days before ending with

[11 July 2022 2:49pm]: No heartbeat detected from the flow run; marking the run as failed.

What is the expected behavior when "cancelling" a flow engaged in executing mapped tasks? (We are also on the dask-executor, with thread-based parallelism.)

Hi I have a question regarding prefect running on kubernetes through helm template deployment. I have troubleshooting connecting the prefect UI with the apollo server. I use a clusterIp service to be able to communicate between the pods. I’m running a service on top of apollo with cluster IP

10.1.70.59

. When I exec the ui pod I can succesfully reach

curl 10.1.70.59:4200/graphql

However within the Prefect UI I can’t connect to the URL. Any idea why ?

Hi guys, does Prefect's

case

statement for True/False logic allow me to do something analogos to this python logic:

a = get_val_or_none()
if not a:
    a = 'some new val'
do_something_with_a(a)

Question on dynamically creating flows; Say I have 3 tasks

@task
def task_1():
  print('1')

@task
def task_2():
  print('2')

@task
def task_3():
  print('3')

And I wanted to give the user the ability to say in which order these should be executed, or who should consume which one. i.e. I want to user to describe a graph of these callables and then for the flow to execute them. How would I do this?

Question about prefect server graphql endpoint. Getting the below error. Any ideas as to why

Hello, got a problem with Prefect server UI not being able to connect to core. The toml file has the line

apollo_url = "http:/<ip of azure vm>:4200/graphql"

. Any help would be much apperciated!

Hello, I am setting up PREFECT on my Openshift environment refering PREFECT Helm (https://github.com/PrefectHQ/server/tree/master/helm/prefect-server#installing-released-versions). BY default, I can see prefect backend is set as CLOUD. My question is , Any options available to set up it with defaulted as "SERVER"

Can anyone help me work out a bug? I’m building the docker image with prefecthq/prefect:1.1.0-python3.8. I’m also registering the flow with prefect 1.1.0 and doing so using the cli. The error is

Failed to load and execute flow run: FlowStorageError('An error occurred while unpickling the flow:\n  AttributeError("Can\'t get attribute \'_make_function\' on <module \'cloudpickle.cloudpickle\' from \'/usr/local/lib/python3.8/site-packages/cloudpickle/cloudpickle.py\'>")\nThis may be due to one of the following version mismatches between the flow build and execution environments:\n  - cloudpickle: (flow built with \'2.1.0\', currently running with \'2.0.0\')')

Hi! Just a question about DeploymentSpec, been searching through the docs and slack and still a bit confused. I'm on orion beta 2.0b6 about to move up to latest: • What will happen to my existing old deployments, will I need to redeploy them? Thanks!

Hi all, Just updated to 2.0b14 and ran into a couple of issues: 1/ Running

prefect cloud login -k KEY -w WORKSPACE

now asks for

"Creating a profile for this Prefect Cloud login. Please specify a profile name:"

This breaks my deployment flow since I need it to be programmatic. I also tried running

prefect profile create

before but that doesn't seem to help. I also can't give the name of an existing profile. Could someone help explain what I'm doing wrong? I tried searching in the docs but maybe I'm missing something 2/ I was able to just hit enter locally and got the following message "Logged in to Prefect Cloud using profile ''." However, if I try to do

prefect cloud login

or

prefect profile inspect

after this, it throws the following error. I had to fix this by manually deleting

profiles.toml

. Code in thread

I’m hoping someone can help me with getting Dask Distributed working inside a k8s cluster. We have our flows configured to use a KubernetesRun. The run config and the executor are using the same image with a base image of

prefecthq/prefect:1.1.0-python3.8

. If we use the

DaskExecutor

with a custom class and kwargs, we get an error message saying we need to install kubectl. If we choose to use a

LocalDaskExecutor

it works just fine. It seems it’s failing some where around attempting to talk between the dask scheduler and workers. We’ve created the roles and role bindings dask requires in order to function properly and we’re not sure if we need to pass in a dask scheduler spec and / or service spec to the dask KubeCluster object? Hoping someone has been able to solve running a temporary, on demand distributed dask cluster in K8S with the KubernetesRun prefect run config