forward 'ip' to LocalCluster (#107)

* forward 'ip' to LocalCluster

* Adding tests

* Flake8 checks

dask_jobqueue/core.py

@@ -202,13 +202,16 @@ def __init__(self,
         #This attribute should be overriden
         self.job_header = None
 
+        # Find the IP address and (if requested) set interface for workers
+        localhost_kwargs = {}
         if interface:
-            host = get_ip_interface(interface)
+            localhost_kwargs['ip'] = get_ip_interface(interface)
             extra += ' --interface  %s ' % interface
         else:
-            host = socket.gethostname()
+            localhost_kwargs['ip'] = socket.gethostname()
+        localhost_kwargs.update(kwargs)
 
-        self.local_cluster = LocalCluster(n_workers=0, ip=host, **kwargs)
+        self.local_cluster = LocalCluster(n_workers=0, **localhost_kwargs)
 
         # Keep information on process, threads and memory, for use in
         # subclasses

dask_jobqueue/tests/test_jobqueue_core.py

@@ -1,4 +1,5 @@
 import pytest
+import socket
 
 from dask_jobqueue import JobQueueCluster, PBSCluster, MoabCluster, SLURMCluster, SGECluster, LSFCluster
 
@@ -27,3 +28,16 @@ def test_repr(Cluster):
         assert 'cores=0' in cluster_repr
         assert 'memory=0 B' in cluster_repr
         assert 'workers=0' in cluster_repr
+
+
+def test_forward_ip():
+    ip = '127.0.0.1'
+    with PBSCluster(walltime='00:02:00', processes=4, cores=8, memory='28GB',
+                    name='dask-worker', ip=ip) as cluster:
+        assert cluster.local_cluster.scheduler.ip == ip
+
+    default_ip = socket.gethostbyname(socket.gethostname())
+    assert default_ip != ip
+    with PBSCluster(walltime='00:02:00', processes=4, cores=8, memory='28GB',
+                    name='dask-worker') as cluster:
+        assert cluster.local_cluster.scheduler.ip == default_ip