Adding destination for client address.

alxmrs · Sep 20, 2022 · 41623ec · 41623ec
1 parent 3c4204d
commit 41623ec
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdks/python/apache_beam/runners/dask/dask_runner.py b/sdks/python/apache_beam/runners/dask/dask_runner.py
@@ -50,7 +50,7 @@ def _parse_timeout(candidate):
 
   @classmethod
   def _add_argparse_args(cls, parser: argparse.ArgumentParser) -> None:
-    parser.add_argument('--dask_client_address', type=str, default=None,
+    parser.add_argument('--dask_client_address', dest='address', type=str, default=None,
                         help='Address of a dask Scheduler server. Will '
                              'default to a `dask.LocalCluster()`.')
     parser.add_argument('--dask_connection_timeout', dest='timeout',