Hi ! I am running the following simple testing flow:

import prefect
from prefect import task, Flow, Parameter, flatten, unmapped
from prefect.executors import DaskExecutor
from prefect.run_configs import LocalRun

@task
def test_parallel(a):
    time.sleep(20)

with Flow("filtering-counting",run_config=LocalRun(), executor = DaskExecutor(address='<tcp://193.10.16.58:3111>')) as flow:
   all_data = Parameter('all_data',default = list(range(10)))
   mapped = test_parallel.map(all_data) 
flow.register(project_name="test")

I have updated to the new version of prefect and I get

prefect.CloudFlowRunner | Flow run RUNNING: terminal tasks are incomplete.

In the setup with the previous version of prefect I was not getting the error. I still get the error even if

flow.set_reference_tasks([mapped])

I have being going through the docs but I still cannot understand where the error is coming from. Thanks!

Hi simone; the log you have provided is not an error and can occur during normal operation, so we’ll need more information to get to the bottom of your issue

Hi! The processing seems to start but keep running, none of the task is completed (not even the parameter one) but beside the log I posted in the message above I don't get any error. I am running a DaskExecutor on a HPC on prem. The agent is started `prefect agent local start --show-flow-logs`inside the code folder . The only other message I have not seen before is this output from docker

INFO[2020-12-19T12:44:57.513535530+01:00] Firewalld: interface br-92be81a89969 already part of docker zone, returning
INFO[0000] Firewalld: docker zone already exists, returning .

I am running prefect 0.14 Thanks a lot for looking into this! Please let me know which other type of info you need to better understand the issue