hey everyone - I’m experiencing a problem where my workflow in a remote dask cluster breaks down after a mapping task. The workflow is terminated on the remote cluster but not in the cloud. any thoughts?

Do you mean your Flow in cloud is staying in a

RUNNING

state after completing on the dask cluster?

after the workflow fails in dask yes

Is there a chance that some error is being raised which kills the process or worker? This wouldn’t give the Cloud runner the ability to report state back to cloud