simone
12/19/2020, 2:18 PMimport 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!Chris White
simone
12/20/2020, 8:15 AMINFO[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 issuerun_config=LocalRun(), executor = DaskExecutor(address='<tcp://193.10.16.58:3111>')
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!