simone12/19/2020, 2:18 PM
I have updated to the new version of prefect and I get
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://126.96.36.199:3111>')) as flow: all_data = Parameter('all_data',default = list(range(10))) mapped = test_parallel.map(all_data) flow.register(project_name="test")
In the setup with the previous version of prefect I was not getting the error. I still get the error even if
prefect.CloudFlowRunner | Flow run RUNNING: terminal tasks are incomplete.
I have being going through the docs but I still cannot understand where the error is coming from. Thanks!
simone12/20/2020, 8:15 AM
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
INFO[2020-12-19T12:44:57.513535530+01:00] Firewalld: interface br-92be81a89969 already part of docker zone, returning INFO Firewalld: docker zone already exists, returning .
are removed from the Flow definition. FYI: Just to make sure that the issue is not cause by the flow I run one of prefect examples and behave the same as my testing flow. Where should I start to troubleshoot? Do you thing is something related to the agent? Thanks for the help!
run_config=LocalRun(), executor = DaskExecutor(address='<tcp://188.8.131.52:3111>')