diff --git a/src/prefect/engine/executors/dask.py b/src/prefect/engine/executors/dask.py index 70e578aebaad..e09aa2357e97 100644 --- a/src/prefect/engine/executors/dask.py +++ b/src/prefect/engine/executors/dask.py @@ -67,12 +67,12 @@ def start(self) -> Iterator[None]: Creates a `dask.distributed.Client` and yields it. """ try: - self.kwargs.update( - silence_logs=logging.CRITICAL if not self.debug else logging.WARNING - ) - with Client( - self.address, processes=self.local_processes, **self.kwargs - ) as client: + if self.address is None: + self.kwargs.update( + silence_logs=logging.CRITICAL if not self.debug else logging.WARNING + ) + self.kwargs.update(processes=self.local_processes) + with Client(self.address, **self.kwargs) as client: self.client = client self.is_started = True yield self.client